proto

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

type KafkaMsg struct {
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Topic   string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Async   bool   `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	Msg     []byte `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type Reply struct {
	Success uint32 `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Fail    uint32 `protobuf:"varint,2,opt,name=fail,proto3" json:"fail,omitempty"`
	// contains filtered or unexported fields
}

type SProxyClient interface {
	SendToKafka(ctx context.Context, in *KafkaMsg, opts ...grpc.CallOption) (*Reply, error)
	SendToKafkaStream(ctx context.Context, opts ...grpc.CallOption) (SProxy_SendToKafkaStreamClient, error)
	SendToInfluxdb(ctx context.Context, in *InfluxdbMsg, opts ...grpc.CallOption) (*Reply, error)
	SendToInfluxdbStream(ctx context.Context, opts ...grpc.CallOption) (SProxy_SendToInfluxdbStreamClient, error)
}

type SProxyServer interface {
	SendToKafka(context.Context, *KafkaMsg) (*Reply, error)
	SendToKafkaStream(SProxy_SendToKafkaStreamServer) error
	SendToInfluxdb(context.Context, *InfluxdbMsg) (*Reply, error)
	SendToInfluxdbStream(SProxy_SendToInfluxdbStreamServer) error
}

type SProxy_SendToInfluxdbStreamClient interface {
	Send(*InfluxdbMsg) error
	CloseAndRecv() (*Reply, error)
	grpc.ClientStream
}

type SProxy_SendToInfluxdbStreamServer interface {
	SendAndClose(*Reply) error
	Recv() (*InfluxdbMsg, error)
	grpc.ServerStream
}

type SProxy_SendToKafkaStreamClient interface {
	Send(*KafkaMsg) error
	CloseAndRecv() (*Reply, error)
	grpc.ClientStream
}

type SProxy_SendToKafkaStreamServer interface {
	SendAndClose(*Reply) error
	Recv() (*KafkaMsg, error)
	grpc.ServerStream
}

type UnimplementedSProxyServer struct {
}