proto

Documentation

Index

• Variables
• func RegisterSProxyServer(s *grpc.Server, srv SProxyServer)
• type InfluxdbMsg
  • func (*InfluxdbMsg) Descriptor() ([]byte, []int)
  • func (x *InfluxdbMsg) GetLines() string
  • func (*InfluxdbMsg) ProtoMessage()
  • func (x *InfluxdbMsg) ProtoReflect() protoreflect.Message
  • func (x *InfluxdbMsg) Reset()
  • func (x *InfluxdbMsg) String() string
• type KafkaMsg
  • func (*KafkaMsg) Descriptor() ([]byte, []int)
  • func (x *KafkaMsg) GetAsync() bool
  • func (x *KafkaMsg) GetCluster() string
  • func (x *KafkaMsg) GetMsg() []byte
  • func (x *KafkaMsg) GetTopic() string
  • func (*KafkaMsg) ProtoMessage()
  • func (x *KafkaMsg) ProtoReflect() protoreflect.Message
  • func (x *KafkaMsg) Reset()
  • func (x *KafkaMsg) String() string
• type Reply
  • func (*Reply) Descriptor() ([]byte, []int)
  • func (x *Reply) GetFail() uint32
  • func (x *Reply) GetSuccess() uint32
  • func (*Reply) ProtoMessage()
  • func (x *Reply) ProtoReflect() protoreflect.Message
  • func (x *Reply) Reset()
  • func (x *Reply) String() string
• type SProxyClient
  • func NewSProxyClient(cc grpc.ClientConnInterface) SProxyClient
• type SProxyServer
• type SProxy_SendToInfluxdbStreamClient
• type SProxy_SendToInfluxdbStreamServer
• type SProxy_SendToKafkaStreamClient
• type SProxy_SendToKafkaStreamServer
• type UnimplementedSProxyServer
  • func (*UnimplementedSProxyServer) SendToInfluxdb(context.Context, *InfluxdbMsg) (*Reply, error)
  • func (*UnimplementedSProxyServer) SendToInfluxdbStream(SProxy_SendToInfluxdbStreamServer) error
  • func (*UnimplementedSProxyServer) SendToKafka(context.Context, *KafkaMsg) (*Reply, error)
  • func (*UnimplementedSProxyServer) SendToKafkaStream(SProxy_SendToKafkaStreamServer) error

Variables

var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterSProxyServer

func RegisterSProxyServer(s *grpc.Server, srv SProxyServer)

Types

type InfluxdbMsg

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

func (*InfluxdbMsg) Descriptor

func (*InfluxdbMsg) Descriptor() ([]byte, []int)

Deprecated: Use InfluxdbMsg.ProtoReflect.Descriptor instead.

func (*InfluxdbMsg) GetLines

func (x *InfluxdbMsg) GetLines() string

func (*InfluxdbMsg) ProtoMessage

func (*InfluxdbMsg) ProtoMessage()

func (*InfluxdbMsg) ProtoReflect

func (x *InfluxdbMsg) ProtoReflect() protoreflect.Message

func (*InfluxdbMsg) Reset

func (x *InfluxdbMsg) Reset()

func (*InfluxdbMsg) String

func (x *InfluxdbMsg) String() string

type KafkaMsg

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
}

func (*KafkaMsg) Descriptor

func (*KafkaMsg) Descriptor() ([]byte, []int)

Deprecated: Use KafkaMsg.ProtoReflect.Descriptor instead.

func (*KafkaMsg) GetAsync

func (x *KafkaMsg) GetAsync() bool

func (*KafkaMsg) GetCluster

func (x *KafkaMsg) GetCluster() string

func (*KafkaMsg) GetMsg

func (x *KafkaMsg) GetMsg() []byte

func (*KafkaMsg) GetTopic

func (x *KafkaMsg) GetTopic() string

func (*KafkaMsg) ProtoMessage

func (*KafkaMsg) ProtoMessage()

func (*KafkaMsg) ProtoReflect

func (x *KafkaMsg) ProtoReflect() protoreflect.Message

func (*KafkaMsg) Reset

func (x *KafkaMsg) Reset()

func (*KafkaMsg) String

func (x *KafkaMsg) String() string

type Reply

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
}

func (*Reply) Descriptor

func (*Reply) Descriptor() ([]byte, []int)

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetFail

func (x *Reply) GetFail() uint32

func (*Reply) GetSuccess

func (x *Reply) GetSuccess() uint32

func (*Reply) ProtoMessage

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect

func (x *Reply) ProtoReflect() protoreflect.Message

func (*Reply) Reset

func (x *Reply) Reset()

func (*Reply) String

func (x *Reply) String() string

type SProxyClient

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)
}

SProxyClient is the client API for SProxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSProxyClient

func NewSProxyClient(cc grpc.ClientConnInterface) SProxyClient

type SProxyServer

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

SProxyServer is the server API for SProxy service.

type SProxy_SendToInfluxdbStreamClient

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

type SProxy_SendToInfluxdbStreamServer

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

type SProxy_SendToKafkaStreamClient

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

type SProxy_SendToKafkaStreamServer

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

type UnimplementedSProxyServer

type UnimplementedSProxyServer struct {
}

UnimplementedSProxyServer can be embedded to have forward compatible implementations.

func (*UnimplementedSProxyServer) SendToInfluxdb

func (*UnimplementedSProxyServer) SendToInfluxdb(context.Context, *InfluxdbMsg) (*Reply, error)

func (*UnimplementedSProxyServer) SendToInfluxdbStream

func (*UnimplementedSProxyServer) SendToInfluxdbStream(SProxy_SendToInfluxdbStreamServer) error

func (*UnimplementedSProxyServer) SendToKafka

func (*UnimplementedSProxyServer) SendToKafka(context.Context, *KafkaMsg) (*Reply, error)

func (*UnimplementedSProxyServer) SendToKafkaStream

func (*UnimplementedSProxyServer) SendToKafkaStream(SProxy_SendToKafkaStreamServer) error