Documentation ¶
Index ¶
- Variables
- func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)
- func RegisterStatusServiceServer(s grpc.ServiceRegistrar, srv StatusServiceServer)
- type EventServiceClient
- type EventServiceServer
- type EventService_FetchReconfigureEventsClient
- type EventService_FetchReconfigureEventsServer
- type FetchReconfigureEventsRequest
- func (*FetchReconfigureEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchReconfigureEventsRequest) GetCluster() *v1.RequestCluster
- func (*FetchReconfigureEventsRequest) ProtoMessage()
- func (x *FetchReconfigureEventsRequest) ProtoReflect() protoreflect.Message
- func (x *FetchReconfigureEventsRequest) Reset()
- func (x *FetchReconfigureEventsRequest) String() string
- type FetchReconfigureEventsResponse
- func (*FetchReconfigureEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (*FetchReconfigureEventsResponse) ProtoMessage()
- func (x *FetchReconfigureEventsResponse) ProtoReflect() protoreflect.Message
- func (x *FetchReconfigureEventsResponse) Reset()
- func (x *FetchReconfigureEventsResponse) String() string
- type StatusServiceClient
- type StatusServiceServer
- type UnimplementedEventServiceServer
- type UnimplementedStatusServiceServer
- type UnsafeEventServiceServer
- type UnsafeStatusServiceServer
- type UpdateExpectedHashRequest
- func (*UpdateExpectedHashRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateExpectedHashRequest) GetCluster() *v1.RequestCluster
- func (x *UpdateExpectedHashRequest) GetHash() string
- func (*UpdateExpectedHashRequest) ProtoMessage()
- func (x *UpdateExpectedHashRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateExpectedHashRequest) Reset()
- func (x *UpdateExpectedHashRequest) String() string
- type UpdateExpectedHashResponse
- type UpdateNodeStatusRequest
- func (*UpdateNodeStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNodeStatusRequest) GetCluster() *v1.RequestCluster
- func (x *UpdateNodeStatusRequest) GetItem() *v11.NodeStatus
- func (*UpdateNodeStatusRequest) ProtoMessage()
- func (x *UpdateNodeStatusRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateNodeStatusRequest) Reset()
- func (x *UpdateNodeStatusRequest) String() string
- type UpdateNodeStatusResponse
Constants ¶
This section is empty.
Variables ¶
var EventService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "kong.relay.service.v1.EventService", HandlerType: (*EventServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "FetchReconfigureEvents", Handler: _EventService_FetchReconfigureEvents_Handler, ServerStreams: true, }, }, Metadata: "kong/relay/service/v1/event.proto", }
EventService_ServiceDesc is the grpc.ServiceDesc for EventService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_kong_relay_service_v1_event_proto protoreflect.FileDescriptor
var File_kong_relay_service_v1_status_proto protoreflect.FileDescriptor
var StatusService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "kong.relay.service.v1.StatusService", HandlerType: (*StatusServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpdateExpectedHash", Handler: _StatusService_UpdateExpectedHash_Handler, }, { MethodName: "UpdateNodeStatus", Handler: _StatusService_UpdateNodeStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "kong/relay/service/v1/status.proto", }
StatusService_ServiceDesc is the grpc.ServiceDesc for StatusService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterEventServiceServer ¶
func RegisterEventServiceServer(s grpc.ServiceRegistrar, srv EventServiceServer)
func RegisterStatusServiceServer ¶
func RegisterStatusServiceServer(s grpc.ServiceRegistrar, srv StatusServiceServer)
Types ¶
type EventServiceClient ¶
type EventServiceClient interface {
FetchReconfigureEvents(ctx context.Context, in *FetchReconfigureEventsRequest, opts ...grpc.CallOption) (EventService_FetchReconfigureEventsClient, error)
}
EventServiceClient is the client API for EventService 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 NewEventServiceClient ¶
func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient
type EventServiceServer ¶
type EventServiceServer interface { FetchReconfigureEvents(*FetchReconfigureEventsRequest, EventService_FetchReconfigureEventsServer) error // contains filtered or unexported methods }
EventServiceServer is the server API for EventService service. All implementations must embed UnimplementedEventServiceServer for forward compatibility
type EventService_FetchReconfigureEventsClient ¶
type EventService_FetchReconfigureEventsClient interface { Recv() (*FetchReconfigureEventsResponse, error) grpc.ClientStream }
type EventService_FetchReconfigureEventsServer ¶
type EventService_FetchReconfigureEventsServer interface { Send(*FetchReconfigureEventsResponse) error grpc.ServerStream }
type FetchReconfigureEventsRequest ¶
type FetchReconfigureEventsRequest struct { Cluster *v1.RequestCluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*FetchReconfigureEventsRequest) Descriptor
deprecated
func (*FetchReconfigureEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchReconfigureEventsRequest.ProtoReflect.Descriptor instead.
func (*FetchReconfigureEventsRequest) GetCluster ¶
func (x *FetchReconfigureEventsRequest) GetCluster() *v1.RequestCluster
func (*FetchReconfigureEventsRequest) ProtoMessage ¶
func (*FetchReconfigureEventsRequest) ProtoMessage()
func (*FetchReconfigureEventsRequest) ProtoReflect ¶
func (x *FetchReconfigureEventsRequest) ProtoReflect() protoreflect.Message
func (*FetchReconfigureEventsRequest) Reset ¶
func (x *FetchReconfigureEventsRequest) Reset()
func (*FetchReconfigureEventsRequest) String ¶
func (x *FetchReconfigureEventsRequest) String() string
type FetchReconfigureEventsResponse ¶
type FetchReconfigureEventsResponse struct {
// contains filtered or unexported fields
}
func (*FetchReconfigureEventsResponse) Descriptor
deprecated
func (*FetchReconfigureEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchReconfigureEventsResponse.ProtoReflect.Descriptor instead.
func (*FetchReconfigureEventsResponse) ProtoMessage ¶
func (*FetchReconfigureEventsResponse) ProtoMessage()
func (*FetchReconfigureEventsResponse) ProtoReflect ¶
func (x *FetchReconfigureEventsResponse) ProtoReflect() protoreflect.Message
func (*FetchReconfigureEventsResponse) Reset ¶
func (x *FetchReconfigureEventsResponse) Reset()
func (*FetchReconfigureEventsResponse) String ¶
func (x *FetchReconfigureEventsResponse) String() string
type StatusServiceClient ¶
type StatusServiceClient interface { UpdateExpectedHash(ctx context.Context, in *UpdateExpectedHashRequest, opts ...grpc.CallOption) (*UpdateExpectedHashResponse, error) UpdateNodeStatus(ctx context.Context, in *UpdateNodeStatusRequest, opts ...grpc.CallOption) (*UpdateNodeStatusResponse, error) }
StatusServiceClient is the client API for StatusService 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 NewStatusServiceClient ¶
func NewStatusServiceClient(cc grpc.ClientConnInterface) StatusServiceClient
type StatusServiceServer ¶
type StatusServiceServer interface { UpdateExpectedHash(context.Context, *UpdateExpectedHashRequest) (*UpdateExpectedHashResponse, error) UpdateNodeStatus(context.Context, *UpdateNodeStatusRequest) (*UpdateNodeStatusResponse, error) // contains filtered or unexported methods }
StatusServiceServer is the server API for StatusService service. All implementations must embed UnimplementedStatusServiceServer for forward compatibility
type UnimplementedEventServiceServer ¶
type UnimplementedEventServiceServer struct { }
UnimplementedEventServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedEventServiceServer) FetchReconfigureEvents ¶
func (UnimplementedEventServiceServer) FetchReconfigureEvents(*FetchReconfigureEventsRequest, EventService_FetchReconfigureEventsServer) error
type UnimplementedStatusServiceServer ¶
type UnimplementedStatusServiceServer struct { }
UnimplementedStatusServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedStatusServiceServer) UpdateExpectedHash ¶
func (UnimplementedStatusServiceServer) UpdateExpectedHash(context.Context, *UpdateExpectedHashRequest) (*UpdateExpectedHashResponse, error)
func (UnimplementedStatusServiceServer) UpdateNodeStatus ¶
func (UnimplementedStatusServiceServer) UpdateNodeStatus(context.Context, *UpdateNodeStatusRequest) (*UpdateNodeStatusResponse, error)
type UnsafeEventServiceServer ¶
type UnsafeEventServiceServer interface {
// contains filtered or unexported methods
}
UnsafeEventServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventServiceServer will result in compilation errors.
type UnsafeStatusServiceServer ¶
type UnsafeStatusServiceServer interface {
// contains filtered or unexported methods
}
UnsafeStatusServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StatusServiceServer will result in compilation errors.
type UpdateExpectedHashRequest ¶
type UpdateExpectedHashRequest struct { Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` Cluster *v1.RequestCluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*UpdateExpectedHashRequest) Descriptor
deprecated
func (*UpdateExpectedHashRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateExpectedHashRequest.ProtoReflect.Descriptor instead.
func (*UpdateExpectedHashRequest) GetCluster ¶
func (x *UpdateExpectedHashRequest) GetCluster() *v1.RequestCluster
func (*UpdateExpectedHashRequest) GetHash ¶
func (x *UpdateExpectedHashRequest) GetHash() string
func (*UpdateExpectedHashRequest) ProtoMessage ¶
func (*UpdateExpectedHashRequest) ProtoMessage()
func (*UpdateExpectedHashRequest) ProtoReflect ¶
func (x *UpdateExpectedHashRequest) ProtoReflect() protoreflect.Message
func (*UpdateExpectedHashRequest) Reset ¶
func (x *UpdateExpectedHashRequest) Reset()
func (*UpdateExpectedHashRequest) String ¶
func (x *UpdateExpectedHashRequest) String() string
type UpdateExpectedHashResponse ¶
type UpdateExpectedHashResponse struct {
// contains filtered or unexported fields
}
func (*UpdateExpectedHashResponse) Descriptor
deprecated
func (*UpdateExpectedHashResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateExpectedHashResponse.ProtoReflect.Descriptor instead.
func (*UpdateExpectedHashResponse) ProtoMessage ¶
func (*UpdateExpectedHashResponse) ProtoMessage()
func (*UpdateExpectedHashResponse) ProtoReflect ¶
func (x *UpdateExpectedHashResponse) ProtoReflect() protoreflect.Message
func (*UpdateExpectedHashResponse) Reset ¶
func (x *UpdateExpectedHashResponse) Reset()
func (*UpdateExpectedHashResponse) String ¶
func (x *UpdateExpectedHashResponse) String() string
type UpdateNodeStatusRequest ¶
type UpdateNodeStatusRequest struct { Item *v11.NodeStatus `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"` Cluster *v1.RequestCluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*UpdateNodeStatusRequest) Descriptor
deprecated
func (*UpdateNodeStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNodeStatusRequest.ProtoReflect.Descriptor instead.
func (*UpdateNodeStatusRequest) GetCluster ¶
func (x *UpdateNodeStatusRequest) GetCluster() *v1.RequestCluster
func (*UpdateNodeStatusRequest) GetItem ¶
func (x *UpdateNodeStatusRequest) GetItem() *v11.NodeStatus
func (*UpdateNodeStatusRequest) ProtoMessage ¶
func (*UpdateNodeStatusRequest) ProtoMessage()
func (*UpdateNodeStatusRequest) ProtoReflect ¶
func (x *UpdateNodeStatusRequest) ProtoReflect() protoreflect.Message
func (*UpdateNodeStatusRequest) Reset ¶
func (x *UpdateNodeStatusRequest) Reset()
func (*UpdateNodeStatusRequest) String ¶
func (x *UpdateNodeStatusRequest) String() string
type UpdateNodeStatusResponse ¶
type UpdateNodeStatusResponse struct {
// contains filtered or unexported fields
}
func (*UpdateNodeStatusResponse) Descriptor
deprecated
func (*UpdateNodeStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNodeStatusResponse.ProtoReflect.Descriptor instead.
func (*UpdateNodeStatusResponse) ProtoMessage ¶
func (*UpdateNodeStatusResponse) ProtoMessage()
func (*UpdateNodeStatusResponse) ProtoReflect ¶
func (x *UpdateNodeStatusResponse) ProtoReflect() protoreflect.Message
func (*UpdateNodeStatusResponse) Reset ¶
func (x *UpdateNodeStatusResponse) Reset()
func (*UpdateNodeStatusResponse) String ¶
func (x *UpdateNodeStatusResponse) String() string