pb

Documentation

Index

• Variables
• func MapFromPB(chunk *LogResponse) events.Log
• func RegisterLogsServiceServer(s grpc.ServiceRegistrar, srv LogsServiceServer)
• type LogRequest
  • func (*LogRequest) Descriptor() ([]byte, []int)
  • func (x *LogRequest) GetExecutionId() string
  • func (*LogRequest) ProtoMessage()
  • func (x *LogRequest) ProtoReflect() protoreflect.Message
  • func (x *LogRequest) Reset()
  • func (x *LogRequest) String() string
• type LogResponse
  • func MapResponseToPB(r events.LogResponse) *LogResponse
  • func (*LogResponse) Descriptor() ([]byte, []int)
  • func (x *LogResponse) GetContent() string
  • func (x *LogResponse) GetError() bool
  • func (x *LogResponse) GetMetadata() map[string]string
  • func (x *LogResponse) GetSource() string
  • func (x *LogResponse) GetTime() *timestamppb.Timestamp
  • func (x *LogResponse) GetType() string
  • func (x *LogResponse) GetVersion() string
  • func (*LogResponse) ProtoMessage()
  • func (x *LogResponse) ProtoReflect() protoreflect.Message
  • func (x *LogResponse) Reset()
  • func (x *LogResponse) String() string
• type LogsServiceClient
  • func NewLogsServiceClient(cc grpc.ClientConnInterface) LogsServiceClient
• type LogsServiceServer
• type LogsService_LogsClient
• type LogsService_LogsServer
• type UnimplementedLogsServiceServer
  • func (UnimplementedLogsServiceServer) Logs(*LogRequest, LogsService_LogsServer) error
• type UnsafeLogsServiceServer

Variables

var File_logs_proto protoreflect.FileDescriptor

var LogsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "logs.LogsService",
	HandlerType: (*LogsServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Logs",
			Handler:       _LogsService_Logs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "logs.proto",
}

LogsService_ServiceDesc is the grpc.ServiceDesc for LogsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func MapFromPB

func MapFromPB(chunk *LogResponse) events.Log

func RegisterLogsServiceServer

func RegisterLogsServiceServer(s grpc.ServiceRegistrar, srv LogsServiceServer)

Types

type LogRequest

type LogRequest struct {
	ExecutionId string `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogRequest) Descriptor

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

Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.

func (*LogRequest) GetExecutionId

func (x *LogRequest) GetExecutionId() string

func (*LogRequest) ProtoMessage

func (*LogRequest) ProtoMessage()

func (*LogRequest) ProtoReflect

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

func (*LogRequest) Reset

func (x *LogRequest) Reset()

func (*LogRequest) String

func (x *LogRequest) String() string

type LogResponse

type LogResponse struct {
	Time     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Content  string                 `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Error    bool                   `protobuf:"varint,3,opt,name=error,proto3" json:"error,omitempty"`
	Type     string                 `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Source   string                 `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	Version  string                 `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	Metadata map[string]string      `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func MapResponseToPB

func MapResponseToPB(r events.LogResponse) *LogResponse

TODO figure out how to pass errors better

func (*LogResponse) Descriptor

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) GetContent

func (x *LogResponse) GetContent() string

func (*LogResponse) GetError

func (x *LogResponse) GetError() bool

func (*LogResponse) GetMetadata

func (x *LogResponse) GetMetadata() map[string]string

func (*LogResponse) GetSource

func (x *LogResponse) GetSource() string

func (*LogResponse) GetTime

func (x *LogResponse) GetTime() *timestamppb.Timestamp

func (*LogResponse) GetType

func (x *LogResponse) GetType() string

func (*LogResponse) GetVersion

func (x *LogResponse) GetVersion() string

func (*LogResponse) ProtoMessage

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect

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

func (*LogResponse) Reset

func (x *LogResponse) Reset()

func (*LogResponse) String

func (x *LogResponse) String() string

type LogsServiceClient

type LogsServiceClient interface {
	Logs(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (LogsService_LogsClient, error)
}

LogsServiceClient is the client API for LogsService 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 NewLogsServiceClient

func NewLogsServiceClient(cc grpc.ClientConnInterface) LogsServiceClient

type LogsServiceServer

type LogsServiceServer interface {
	Logs(*LogRequest, LogsService_LogsServer) error
	// contains filtered or unexported methods
}

LogsServiceServer is the server API for LogsService service. All implementations must embed UnimplementedLogsServiceServer for forward compatibility

type LogsService_LogsClient

type LogsService_LogsClient interface {
	Recv() (*LogResponse, error)
	grpc.ClientStream
}

type LogsService_LogsServer

type LogsService_LogsServer interface {
	Send(*LogResponse) error
	grpc.ServerStream
}

type UnimplementedLogsServiceServer

type UnimplementedLogsServiceServer struct {
}

UnimplementedLogsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLogsServiceServer) Logs

func (UnimplementedLogsServiceServer) Logs(*LogRequest, LogsService_LogsServer) error

type UnsafeLogsServiceServer

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

UnsafeLogsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogsServiceServer will result in compilation errors.