gg_bflow

type DiscreteFlowRes struct {
	Byte []byte `protobuf:"bytes,1,opt,name=Byte,proto3" json:"Byte,omitempty"`
	// contains filtered or unexported fields
}

type FlowRes struct {
	Byte []byte `protobuf:"bytes,1,opt,name=Byte,proto3" json:"Byte,omitempty"`
	Info string `protobuf:"bytes,2,opt,name=Info,proto3" json:"Info,omitempty"`
	// contains filtered or unexported fields
}

type GGBFlowClient interface {
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckRes, error)
}

type GGBFlowLoaderClient interface {
	LoadDiscreteFlow(ctx context.Context, in *LoadDiscreteFlowArg, opts ...grpc.CallOption) (*DiscreteFlowRes, error)
	LoadFlow(ctx context.Context, in *LoadFlowArg, opts ...grpc.CallOption) (GGBFlowLoader_LoadFlowClient, error)
	LoadMeta(ctx context.Context, in *LoadMetaArg, opts ...grpc.CallOption) (*MetaRes, error)
}

type GGBFlowLoaderServer interface {
	LoadDiscreteFlow(context.Context, *LoadDiscreteFlowArg) (*DiscreteFlowRes, error)
	LoadFlow(*LoadFlowArg, GGBFlowLoader_LoadFlowServer) error
	LoadMeta(context.Context, *LoadMetaArg) (*MetaRes, error)
	// contains filtered or unexported methods
}

type GGBFlowLoader_LoadFlowClient interface {
	Recv() (*FlowRes, error)
	grpc.ClientStream
}

type GGBFlowLoader_LoadFlowServer interface {
	Send(*FlowRes) error
	grpc.ServerStream
}

type GGBFlowSenderClient interface {
	SendOneFlow(ctx context.Context, in *SendFlowArg, opts ...grpc.CallOption) (*Ok, error)
	SendFlow(ctx context.Context, opts ...grpc.CallOption) (GGBFlowSender_SendFlowClient, error)
	SendMeta(ctx context.Context, in *SendMetaArg, opts ...grpc.CallOption) (*Ok, error)
}

type GGBFlowSenderServer interface {
	SendOneFlow(context.Context, *SendFlowArg) (*Ok, error)
	SendFlow(GGBFlowSender_SendFlowServer) error
	SendMeta(context.Context, *SendMetaArg) (*Ok, error)
	// contains filtered or unexported methods
}

type GGBFlowSender_SendFlowClient interface {
	Send(*SendFlowArg) error
	CloseAndRecv() (*Ok, error)
	grpc.ClientStream
}

type GGBFlowSender_SendFlowServer interface {
	SendAndClose(*Ok) error
	Recv() (*SendFlowArg, error)
	grpc.ServerStream
}

type GGBFlowServer interface {
	HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckRes, error)
	// contains filtered or unexported methods
}

type HealthCheckRes struct {
	Uptime string `protobuf:"bytes,1,opt,name=Uptime,proto3" json:"Uptime,omitempty"`
	Meta   string `protobuf:"bytes,2,opt,name=Meta,proto3" json:"Meta,omitempty"`
	// contains filtered or unexported fields
}

type LoadDiscreteFlowArg struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

type LoadFlowArg struct {
	Key  string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Rate int64  `protobuf:"varint,2,opt,name=Rate,proto3" json:"Rate,omitempty"`
	// contains filtered or unexported fields
}

type LoadMetaArg struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

type MetaRes struct {
	Key       string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Meta      string `protobuf:"bytes,2,opt,name=Meta,proto3" json:"Meta,omitempty"`
	CreatedAt int64  `protobuf:"varint,3,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	UpdatedAt int64  `protobuf:"varint,4,opt,name=UpdatedAt,proto3" json:"UpdatedAt,omitempty"`
	// contains filtered or unexported fields
}

type Ok struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	Meta    string `protobuf:"bytes,2,opt,name=Meta,proto3" json:"Meta,omitempty"`
	// contains filtered or unexported fields
}

type SendFlowArg struct {
	Key  string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Byte []byte `protobuf:"bytes,2,opt,name=Byte,proto3" json:"Byte,omitempty"`
	// contains filtered or unexported fields
}

type SendMetaArg struct {
	Key  string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Meta string `protobuf:"bytes,2,opt,name=Meta,proto3" json:"Meta,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedGGBFlowLoaderServer struct {
}

type UnimplementedGGBFlowSenderServer struct {
}

type UnimplementedGGBFlowServer struct {
}

type UnsafeGGBFlowLoaderServer interface {
	// contains filtered or unexported methods
}

type UnsafeGGBFlowSenderServer interface {
	// contains filtered or unexported methods
}

type UnsafeGGBFlowServer interface {
	// contains filtered or unexported methods
}