input

Jun 8, 2024

Changes in this version

type Integration_ProcessLogClient

+ Recv func() (*Ack, error)

type Integration_ProcessLogServer

+ Send func(*Ack) error

Jun 6, 2024

Changes in this version

+ const Integration_ProcessLog_FullMethodName

+ var File_input_proto protoreflect.FileDescriptor

+ var Integration_ServiceDesc = grpc.ServiceDesc

+ func RegisterIntegrationServer(s grpc.ServiceRegistrar, srv IntegrationServer)

+ type Ack struct

+ LastId string

+ func (*Ack) Descriptor() ([]byte, []int)

+ func (*Ack) ProtoMessage()

+ func (x *Ack) GetLastId() string

+ func (x *Ack) ProtoReflect() protoreflect.Message

+ func (x *Ack) Reset()

+ func (x *Ack) String() string

+ type IntegrationClient interface

+ ProcessLog func(ctx context.Context, opts ...grpc.CallOption) (Integration_ProcessLogClient, error)

+ func NewIntegrationClient(cc grpc.ClientConnInterface) IntegrationClient

+ type IntegrationServer interface

+ ProcessLog func(Integration_ProcessLogServer) error

+ type Integration_ProcessLogClient interface

+ CloseAndRecv func() (*Ack, error)

+ Send func(*Log) error

+ type Integration_ProcessLogServer interface

+ Recv func() (*Log, error)

+ SendAndClose func(*Ack) error

+ type Log struct

+ DataSource string

+ DataType string

+ Id string

+ Raw string

+ TenantId string

+ Timestamp string

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

+ func (x *Log) GetDataSource() string

+ func (x *Log) GetDataType() string

+ func (x *Log) GetId() string

+ func (x *Log) GetRaw() string

+ func (x *Log) GetTenantId() string

+ func (x *Log) GetTimestamp() string

+ func (x *Log) ProtoReflect() protoreflect.Message

+ func (x *Log) Reset()

+ func (x *Log) String() string

+ type UnimplementedIntegrationServer struct

+ func (UnimplementedIntegrationServer) ProcessLog(Integration_ProcessLogServer) error

+ type UnsafeIntegrationServer interface