cluster

Documentation

Index

• Constants
• Variables
• func RegisterClusterInterfaceServer(s grpc.ServiceRegistrar, srv ClusterInterfaceServer)
• type Cluster
  • func (*Cluster) Descriptor() ([]byte, []int)
  • func (x *Cluster) GetName() string
  • func (x *Cluster) GetVersion() string
  • func (*Cluster) ProtoMessage()
  • func (x *Cluster) ProtoReflect() protoreflect.Message
  • func (x *Cluster) Reset()
  • func (x *Cluster) String() string
• type ClusterInterfaceClient
  • func NewClusterInterfaceClient(cc grpc.ClientConnInterface) ClusterInterfaceClient
• type ClusterInterfaceServer
• type ClusterInterface_GetLogsClient
• type ClusterInterface_GetLogsServer
• type LogRequest
  • func (*LogRequest) Descriptor() ([]byte, []int)
  • func (x *LogRequest) GetTailLines() int32
  • func (*LogRequest) ProtoMessage()
  • func (x *LogRequest) ProtoReflect() protoreflect.Message
  • func (x *LogRequest) Reset()
  • func (x *LogRequest) String() string
• type LogResponse
  • func (*LogResponse) Descriptor() ([]byte, []int)
  • func (x *LogResponse) GetLog() string
  • func (*LogResponse) ProtoMessage()
  • func (x *LogResponse) ProtoReflect() protoreflect.Message
  • func (x *LogResponse) Reset()
  • func (x *LogResponse) String() string
• type UnimplementedClusterInterfaceServer
  • func (UnimplementedClusterInterfaceServer) GetLogs(grpc.BidiStreamingServer[LogRequest, LogResponse]) error
  • func (UnimplementedClusterInterfaceServer) Info(context.Context, *emptypb.Empty) (*Cluster, error)
  • func (UnimplementedClusterInterfaceServer) Ping(context.Context, *emptypb.Empty) (*common.Msg, error)
• type UnsafeClusterInterfaceServer

Constants

const (
	ClusterInterface_Ping_FullMethodName    = "/sidecar.api.cluster.ClusterInterface/Ping"
	ClusterInterface_GetLogs_FullMethodName = "/sidecar.api.cluster.ClusterInterface/GetLogs"
	ClusterInterface_Info_FullMethodName    = "/sidecar.api.cluster.ClusterInterface/Info"
)

Variables

var ClusterInterface_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sidecar.api.cluster.ClusterInterface",
	HandlerType: (*ClusterInterfaceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _ClusterInterface_Ping_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _ClusterInterface_Info_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetLogs",
			Handler:       _ClusterInterface_GetLogs_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "internal/repository/sidecar/api/cluster/cluster.proto",
}

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

var File_internal_repository_sidecar_api_cluster_cluster_proto protoreflect.FileDescriptor

var File_internal_repository_sidecar_api_cluster_message_proto protoreflect.FileDescriptor

Functions

func RegisterClusterInterfaceServer

func RegisterClusterInterfaceServer(s grpc.ServiceRegistrar, srv ClusterInterfaceServer)

Types

type Cluster

type Cluster struct {
	Name    string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetName

func (x *Cluster) GetName() string

func (*Cluster) GetVersion

func (x *Cluster) GetVersion() string

func (*Cluster) ProtoMessage

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect

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

func (*Cluster) Reset

func (x *Cluster) Reset()

func (*Cluster) String

func (x *Cluster) String() string

type ClusterInterfaceClient

type ClusterInterfaceClient 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)
	Info(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Cluster, error)
}

ClusterInterfaceClient is the client API for ClusterInterface 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 NewClusterInterfaceClient

func NewClusterInterfaceClient(cc grpc.ClientConnInterface) ClusterInterfaceClient

type ClusterInterfaceServer

type ClusterInterfaceServer interface {
	Ping(context.Context, *emptypb.Empty) (*common.Msg, error)
	GetLogs(grpc.BidiStreamingServer[LogRequest, LogResponse]) error
	Info(context.Context, *emptypb.Empty) (*Cluster, error)
	// contains filtered or unexported methods
}

ClusterInterfaceServer is the server API for ClusterInterface service. All implementations must embed UnimplementedClusterInterfaceServer for forward compatibility.

type ClusterInterface_GetLogsClient

type ClusterInterface_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 ClusterInterface_GetLogsServer

type ClusterInterface_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

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

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 UnimplementedClusterInterfaceServer

type UnimplementedClusterInterfaceServer struct{}

UnimplementedClusterInterfaceServer 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 (UnimplementedClusterInterfaceServer) GetLogs

func (UnimplementedClusterInterfaceServer) GetLogs(grpc.BidiStreamingServer[LogRequest, LogResponse]) error

func (UnimplementedClusterInterfaceServer) Info

func (UnimplementedClusterInterfaceServer) Info(context.Context, *emptypb.Empty) (*Cluster, error)

func (UnimplementedClusterInterfaceServer) Ping

func (UnimplementedClusterInterfaceServer) Ping(context.Context, *emptypb.Empty) (*common.Msg, error)

type UnsafeClusterInterfaceServer

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

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