server

Documentation

Index

• Variables
• func RegisterLoggerServer(s grpc.ServiceRegistrar, srv LoggerServer)
• type Empty
  • func (*Empty) Descriptor() ([]byte, []int)
  • func (*Empty) ProtoMessage()
  • func (x *Empty) ProtoReflect() protoreflect.Message
  • func (x *Empty) Reset()
  • func (x *Empty) String() string
• type Generator
• type LogMessage
  • func (*LogMessage) Descriptor() ([]byte, []int)
  • func (x *LogMessage) GetEventAt() *timestamp.Timestamp
  • func (x *LogMessage) GetLabel() string
  • func (x *LogMessage) GetText() string
  • func (*LogMessage) ProtoMessage()
  • func (x *LogMessage) ProtoReflect() protoreflect.Message
  • func (x *LogMessage) Reset()
  • func (x *LogMessage) String() string
• type LoggerClient
  • func NewLoggerClient(cc grpc.ClientConnInterface) LoggerClient
• type LoggerServer
• type Logger_FetchLogsClient
• type Logger_FetchLogsServer
• type Server
  • func New(svc Generator) *Server
  • func (s *Server) FetchLogs(_ *Empty, stream Logger_FetchLogsServer) error
  • func (s *Server) Serve(addr string) error
• type UnimplementedLoggerServer
  • func (UnimplementedLoggerServer) FetchLogs(*Empty, Logger_FetchLogsServer) error
• type UnsafeLoggerServer

Variables

var File_logger_proto protoreflect.FileDescriptor

Functions

func RegisterLoggerServer

func RegisterLoggerServer(s grpc.ServiceRegistrar, srv LoggerServer)

Types

type Empty

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type Generator

type Generator interface {
	Logs() chan generator.Message
}

type LogMessage

type LogMessage struct {
	Label   string               `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Text    string               `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	EventAt *timestamp.Timestamp `protobuf:"bytes,3,opt,name=event_at,json=eventAt,proto3" json:"event_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetEventAt

func (x *LogMessage) GetEventAt() *timestamp.Timestamp

func (*LogMessage) GetLabel

func (x *LogMessage) GetLabel() string

func (*LogMessage) GetText

func (x *LogMessage) GetText() string

func (*LogMessage) ProtoMessage

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect

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

func (*LogMessage) Reset

func (x *LogMessage) Reset()

func (*LogMessage) String

func (x *LogMessage) String() string

type LoggerClient

type LoggerClient interface {
	FetchLogs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Logger_FetchLogsClient, error)
}

LoggerClient is the client API for Logger 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 NewLoggerClient

func NewLoggerClient(cc grpc.ClientConnInterface) LoggerClient

type LoggerServer

type LoggerServer interface {
	FetchLogs(*Empty, Logger_FetchLogsServer) error
	// contains filtered or unexported methods
}

LoggerServer is the server API for Logger service. All implementations must embed UnimplementedLoggerServer for forward compatibility

type Logger_FetchLogsClient

type Logger_FetchLogsClient interface {
	Recv() (*LogMessage, error)
	grpc.ClientStream
}

type Logger_FetchLogsServer

type Logger_FetchLogsServer interface {
	Send(*LogMessage) error
	grpc.ServerStream
}

type Server

type Server struct {
	UnimplementedLoggerServer
	// contains filtered or unexported fields
}

func New

func New(svc Generator) *Server

func (*Server) FetchLogs

func (s *Server) FetchLogs(_ *Empty, stream Logger_FetchLogsServer) error

func (*Server) Serve

func (s *Server) Serve(addr string) error

type UnimplementedLoggerServer

type UnimplementedLoggerServer struct {
}

UnimplementedLoggerServer must be embedded to have forward compatible implementations.

func (UnimplementedLoggerServer) FetchLogs

func (UnimplementedLoggerServer) FetchLogs(*Empty, Logger_FetchLogsServer) error

type UnsafeLoggerServer

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

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