Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterLogInterfaceServer(s grpc.ServiceRegistrar, srv LogInterfaceServer)
- type LogInterfaceClient
- type LogInterfaceServer
- type LogInterface_GetLogsClient
- type LogInterface_GetLogsServer
- type LogRequest
- type LogResponse
- type UnimplementedLogInterfaceServer
- type UnsafeLogInterfaceServer
Constants ¶
const ( LogInterface_Ping_FullMethodName = "/infrastructure.api.log.LogInterface/Ping" LogInterface_GetLogs_FullMethodName = "/infrastructure.api.log.LogInterface/GetLogs" )
Variables ¶
var File_internal_repository_infrastructure_api_log_log_proto protoreflect.FileDescriptor
var File_internal_repository_infrastructure_api_log_message_proto protoreflect.FileDescriptor
var LogInterface_ServiceDesc = grpc.ServiceDesc{ ServiceName: "infrastructure.api.log.LogInterface", HandlerType: (*LogInterfaceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ping", Handler: _LogInterface_Ping_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetLogs", Handler: _LogInterface_GetLogs_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "internal/repository/infrastructure/api/log/log.proto", }
LogInterface_ServiceDesc is the grpc.ServiceDesc for LogInterface service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLogInterfaceServer ¶
func RegisterLogInterfaceServer(s grpc.ServiceRegistrar, srv LogInterfaceServer)
Types ¶
type LogInterfaceClient ¶
type LogInterfaceClient interface { Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*common.Msg, error) GetLogs(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[LogRequest, LogResponse], error) }
LogInterfaceClient is the client API for LogInterface 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 NewLogInterfaceClient ¶
func NewLogInterfaceClient(cc grpc.ClientConnInterface) LogInterfaceClient
type LogInterfaceServer ¶
type LogInterfaceServer interface { Ping(context.Context, *emptypb.Empty) (*common.Msg, error) GetLogs(grpc.BidiStreamingServer[LogRequest, LogResponse]) error // contains filtered or unexported methods }
LogInterfaceServer is the server API for LogInterface service. All implementations must embed UnimplementedLogInterfaceServer for forward compatibility.
type LogInterface_GetLogsClient ¶
type LogInterface_GetLogsClient = grpc.BidiStreamingClient[LogRequest, LogResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LogInterface_GetLogsServer ¶
type LogInterface_GetLogsServer = grpc.BidiStreamingServer[LogRequest, LogResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LogRequest ¶
type LogRequest struct { TailLines int32 `protobuf:"varint,1,opt,name=tail_lines,proto3" json:"tail_lines,omitempty"` // contains filtered or unexported fields }
func (*LogRequest) Descriptor
deprecated
func (*LogRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogRequest.ProtoReflect.Descriptor instead.
func (*LogRequest) GetTailLines ¶
func (x *LogRequest) GetTailLines() int32
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 { Log string `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"` // contains filtered or unexported fields }
func (*LogResponse) Descriptor
deprecated
func (*LogResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.
func (*LogResponse) GetLog ¶
func (x *LogResponse) GetLog() 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 UnimplementedLogInterfaceServer ¶
type UnimplementedLogInterfaceServer struct{}
UnimplementedLogInterfaceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedLogInterfaceServer) GetLogs ¶
func (UnimplementedLogInterfaceServer) GetLogs(grpc.BidiStreamingServer[LogRequest, LogResponse]) error
type UnsafeLogInterfaceServer ¶
type UnsafeLogInterfaceServer interface {
// contains filtered or unexported methods
}
UnsafeLogInterfaceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogInterfaceServer will result in compilation errors.