Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterIntegrationServer(s grpc.ServiceRegistrar, srv IntegrationServer)
- type Ack
- type IntegrationClient
- type IntegrationServer
- type Integration_ProcessLogClient
- type Integration_ProcessLogServer
- type Log
- func (*Log) Descriptor() ([]byte, []int)deprecated
- 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 (*Log) ProtoMessage()
- func (x *Log) ProtoReflect() protoreflect.Message
- func (x *Log) Reset()
- func (x *Log) String() string
- type UnimplementedIntegrationServer
- type UnsafeIntegrationServer
Constants ¶
const (
Integration_ProcessLog_FullMethodName = "/input.Integration/ProcessLog"
)
Variables ¶
var File_input_proto protoreflect.FileDescriptor
var Integration_ServiceDesc = grpc.ServiceDesc{ ServiceName: "input.Integration", HandlerType: (*IntegrationServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "ProcessLog", Handler: _Integration_ProcessLog_Handler, ClientStreams: true, }, }, Metadata: "input.proto", }
Integration_ServiceDesc is the grpc.ServiceDesc for Integration service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIntegrationServer ¶
func RegisterIntegrationServer(s grpc.ServiceRegistrar, srv IntegrationServer)
Types ¶
type Ack ¶
type Ack struct {
LastId string `protobuf:"bytes,1,opt,name=lastId,proto3" json:"lastId,omitempty"`
// contains filtered or unexported fields
}
func (*Ack) Descriptor
deprecated
func (*Ack) ProtoMessage ¶
func (*Ack) ProtoMessage()
func (*Ack) ProtoReflect ¶
func (x *Ack) ProtoReflect() protoreflect.Message
type IntegrationClient ¶
type IntegrationClient interface {
ProcessLog(ctx context.Context, opts ...grpc.CallOption) (Integration_ProcessLogClient, error)
}
IntegrationClient is the client API for Integration service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIntegrationClient ¶
func NewIntegrationClient(cc grpc.ClientConnInterface) IntegrationClient
type IntegrationServer ¶
type IntegrationServer interface {
ProcessLog(Integration_ProcessLogServer) error
// contains filtered or unexported methods
}
IntegrationServer is the server API for Integration service. All implementations must embed UnimplementedIntegrationServer for forward compatibility
type Log ¶
type Log struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
DataType string `protobuf:"bytes,2,opt,name=dataType,proto3" json:"dataType,omitempty"`
DataSource string `protobuf:"bytes,3,opt,name=dataSource,proto3" json:"dataSource,omitempty"`
Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
TenantId string `protobuf:"bytes,5,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
Raw string `protobuf:"bytes,6,opt,name=raw,proto3" json:"raw,omitempty"`
// contains filtered or unexported fields
}
func (*Log) Descriptor
deprecated
func (*Log) GetDataSource ¶
func (*Log) GetDataType ¶
func (*Log) GetTenantId ¶
func (*Log) GetTimestamp ¶
func (*Log) ProtoMessage ¶
func (*Log) ProtoMessage()
func (*Log) ProtoReflect ¶
func (x *Log) ProtoReflect() protoreflect.Message
type UnimplementedIntegrationServer ¶
type UnimplementedIntegrationServer struct {
}
UnimplementedIntegrationServer must be embedded to have forward compatible implementations.
func (UnimplementedIntegrationServer) ProcessLog ¶
func (UnimplementedIntegrationServer) ProcessLog(Integration_ProcessLogServer) error
type UnsafeIntegrationServer ¶
type UnsafeIntegrationServer interface {
// contains filtered or unexported methods
}
UnsafeIntegrationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IntegrationServer will result in compilation errors.
Source Files