api

package
v0.0.0-...-87f11ff Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AgentApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "AgentApi",
	HandlerType: (*AgentApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Status",
			Handler:    _AgentApi_Status_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _AgentApi_Shutdown_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Logs",
			Handler:       _AgentApi_Logs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "application/api/agent/agent.proto",
}

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

View Source 
var File_application_api_agent_agent_proto protoreflect.FileDescriptor

Functions

func RegisterAgentApiServer 

func RegisterAgentApiServer(s grpc.ServiceRegistrar, srv AgentApiServer)

Types

type AgentApiClient 

type AgentApiClient interface {
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (AgentApi_LogsClient, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

AgentApiClient is the client API for AgentApi 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 NewAgentApiClient 

func NewAgentApiClient(cc grpc.ClientConnInterface) AgentApiClient

type AgentApiServer 

type AgentApiServer interface {
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	Logs(*LogsRequest, AgentApi_LogsServer) error
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	// contains filtered or unexported methods
}

AgentApiServer is the server API for AgentApi service. All implementations must embed UnimplementedAgentApiServer for forward compatibility

type AgentApi_LogsClient 

type AgentApi_LogsClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type AgentApi_LogsServer 

type AgentApi_LogsServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}

type LogEntry 

type LogEntry struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetMessage 

func (x *LogEntry) GetMessage() string

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type LogsRequest 

type LogsRequest struct {
	ListenerName string `protobuf:"bytes,1,opt,name=listenerName,proto3" json:"listenerName,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsRequest) Descriptor deprecated 

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

Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.

func (*LogsRequest) GetListenerName 

func (x *LogsRequest) GetListenerName() string

func (*LogsRequest) ProtoMessage 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) ProtoReflect 

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

func (*LogsRequest) Reset 

func (x *LogsRequest) Reset()

func (*LogsRequest) String 

func (x *LogsRequest) String() string

type ShutdownRequest 

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

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

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

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

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

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type StatusRequest 

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

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

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

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetVersion 

func (x *StatusResponse) GetVersion() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type UnimplementedAgentApiServer 

type UnimplementedAgentApiServer struct {
}

UnimplementedAgentApiServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentApiServer) Logs 

func (UnimplementedAgentApiServer) Logs(*LogsRequest, AgentApi_LogsServer) error

func (UnimplementedAgentApiServer) Shutdown 

func (UnimplementedAgentApiServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

func (UnimplementedAgentApiServer) Status 

func (UnimplementedAgentApiServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeAgentApiServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.