rpc

package
v0.1.8 Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2022 License: MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ticker.rpc.EventStream",
	HandlerType: (*EventStreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Emit",
			Handler:    _EventStream_Emit_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _EventStream_Stream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Listen",
			Handler:       _EventStream_Listen_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _EventStream_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Acknowledge",
			Handler:       _EventStream_Acknowledge_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "event_stream.proto",
}

EventStream_ServiceDesc is the grpc.ServiceDesc for EventStream 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_event_stream_proto protoreflect.FileDescriptor
View Source 
var File_maintenance_proto protoreflect.FileDescriptor
View Source 
var Maintenance_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ticker.rpc.Maintenance",
	HandlerType: (*MaintenanceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetServerState",
			Handler:    _Maintenance_GetServerState_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Maintenance_Shutdown_Handler,
		},
		{
			MethodName: "GetSubscriptions",
			Handler:    _Maintenance_GetSubscriptions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "maintenance.proto",
}

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

Functions

func ProtoToBracket 

func ProtoToBracket(b *Bracket) *es.Bracket

func ProtoToEvent 

func ProtoToEvent(e *Event) *es.Event

func ProtoToSelector 

func ProtoToSelector(s *Selector) *es.Selector

func RegisterEventStreamServer added in v0.1.1 

func RegisterEventStreamServer(s grpc.ServiceRegistrar, srv EventStreamServer)

func RegisterMaintenanceServer added in v0.1.1 

func RegisterMaintenanceServer(s grpc.ServiceRegistrar, srv MaintenanceServer)

Types

type Ack added in v0.1.1 

type Ack struct {
	PersistentClientId string `protobuf:"bytes,1,opt,name=persistent_client_id,json=persistentClientId,proto3" json:"persistent_client_id,omitempty"`
	Sequence           int64  `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetPersistentClientId added in v0.1.4 

func (x *Ack) GetPersistentClientId() string

func (*Ack) GetSequence added in v0.1.1 

func (x *Ack) GetSequence() int64

func (*Ack) ProtoMessage added in v0.1.1 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect added in v0.1.1 

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

func (*Ack) Reset added in v0.1.1 

func (x *Ack) Reset()

func (*Ack) String added in v0.1.1 

func (x *Ack) String() string

type Bracket added in v0.1.1 

type Bracket struct {
	FirstSequence int64 `protobuf:"varint,1,opt,name=first_sequence,json=firstSequence,proto3" json:"first_sequence,omitempty"`
	LastSequence  int64 `protobuf:"varint,2,opt,name=last_sequence,json=lastSequence,proto3" json:"last_sequence,omitempty"`
	// contains filtered or unexported fields
}

func BracketToProto added in v0.1.1 

func BracketToProto(b *es.Bracket) *Bracket

func (*Bracket) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use Bracket.ProtoReflect.Descriptor instead.

func (*Bracket) GetFirstSequence added in v0.1.1 

func (x *Bracket) GetFirstSequence() int64

func (*Bracket) GetLastSequence added in v0.1.1 

func (x *Bracket) GetLastSequence() int64

func (*Bracket) ProtoMessage added in v0.1.1 

func (*Bracket) ProtoMessage()

func (*Bracket) ProtoReflect added in v0.1.1 

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

func (*Bracket) Reset added in v0.1.1 

func (x *Bracket) Reset()

func (*Bracket) String added in v0.1.1 

func (x *Bracket) String() string

type Event added in v0.1.1 

type Event struct {
	Sequence   int64                  `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Aggregate  []string               `protobuf:"bytes,2,rep,name=aggregate,proto3" json:"aggregate,omitempty"`
	Type       string                 `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	Payload    *structpb.Struct       `protobuf:"bytes,10,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func EventToProto added in v0.1.1 

func EventToProto(e *es.Event) *Event

func (*Event) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAggregate added in v0.1.1 

func (x *Event) GetAggregate() []string

func (*Event) GetOccurredAt added in v0.1.1 

func (x *Event) GetOccurredAt() *timestamppb.Timestamp

func (*Event) GetPayload added in v0.1.1 

func (x *Event) GetPayload() *structpb.Struct

func (*Event) GetSequence added in v0.1.1 

func (x *Event) GetSequence() int64

func (*Event) GetType added in v0.1.1 

func (x *Event) GetType() string

func (*Event) ProtoMessage added in v0.1.1 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.1.1 

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

func (*Event) Reset added in v0.1.1 

func (x *Event) Reset()

func (*Event) String added in v0.1.1 

func (x *Event) String() string

type EventStreamClient added in v0.1.1 

type EventStreamClient interface {
	Emit(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Published, error)
	Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (EventStream_StreamClient, error)
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (EventStream_ListenClient, error)
	Subscribe(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (EventStream_SubscribeClient, error)
	Acknowledge(ctx context.Context, opts ...grpc.CallOption) (EventStream_AcknowledgeClient, error)
}

EventStreamClient is the client API for EventStream 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 NewEventStreamClient added in v0.1.1 

func NewEventStreamClient(cc grpc.ClientConnInterface) EventStreamClient

type EventStreamServer added in v0.1.1 

type EventStreamServer interface {
	Emit(context.Context, *Event) (*Published, error)
	Stream(*StreamRequest, EventStream_StreamServer) error
	Listen(*ListenRequest, EventStream_ListenServer) error
	Subscribe(*SubscriptionRequest, EventStream_SubscribeServer) error
	Acknowledge(EventStream_AcknowledgeServer) error
	// contains filtered or unexported methods
}

EventStreamServer is the server API for EventStream service. All implementations must embed UnimplementedEventStreamServer for forward compatibility

type EventStream_AcknowledgeClient added in v0.1.1 

type EventStream_AcknowledgeClient interface {
	Send(*Ack) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type EventStream_AcknowledgeServer added in v0.1.1 

type EventStream_AcknowledgeServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*Ack, error)
	grpc.ServerStream
}

type EventStream_ListenClient added in v0.1.5 

type EventStream_ListenClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStream_ListenServer added in v0.1.5 

type EventStream_ListenServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type EventStream_StreamClient added in v0.1.1 

type EventStream_StreamClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStream_StreamServer added in v0.1.1 

type EventStream_StreamServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type EventStream_SubscribeClient added in v0.1.1 

type EventStream_SubscribeClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStream_SubscribeServer added in v0.1.1 

type EventStream_SubscribeServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type ListenRequest added in v0.1.5 

type ListenRequest struct {
	Selector *Selector `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenRequest) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) GetSelector added in v0.1.5 

func (x *ListenRequest) GetSelector() *Selector

func (*ListenRequest) ProtoMessage added in v0.1.5 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect added in v0.1.5 

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

func (*ListenRequest) Reset added in v0.1.5 

func (x *ListenRequest) Reset()

func (*ListenRequest) String added in v0.1.5 

func (x *ListenRequest) String() string

type MaintenanceClient added in v0.1.1 

type MaintenanceClient interface {
	GetServerState(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServerState, error)
	Shutdown(ctx context.Context, in *ShutdownParameters, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetSubscriptions(ctx context.Context, in *SubscriptionsRequest, opts ...grpc.CallOption) (*SubscriptionsResponse, error)
}

MaintenanceClient is the client API for Maintenance 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 NewMaintenanceClient added in v0.1.1 

func NewMaintenanceClient(cc grpc.ClientConnInterface) MaintenanceClient

type MaintenanceServer added in v0.1.1 

type MaintenanceServer interface {
	GetServerState(context.Context, *emptypb.Empty) (*ServerState, error)
	Shutdown(context.Context, *ShutdownParameters) (*emptypb.Empty, error)
	GetSubscriptions(context.Context, *SubscriptionsRequest) (*SubscriptionsResponse, error)
	// contains filtered or unexported methods
}

MaintenanceServer is the server API for Maintenance service. All implementations must embed UnimplementedMaintenanceServer for forward compatibility

type Published added in v0.1.4 

type Published struct {
	Sequence int64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*Published) Descriptor deprecated added in v0.1.4 

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

Deprecated: Use Published.ProtoReflect.Descriptor instead.

func (*Published) GetSequence added in v0.1.4 

func (x *Published) GetSequence() int64

func (*Published) ProtoMessage added in v0.1.4 

func (*Published) ProtoMessage()

func (*Published) ProtoReflect added in v0.1.4 

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

func (*Published) Reset added in v0.1.4 

func (x *Published) Reset()

func (*Published) String added in v0.1.4 

func (x *Published) String() string

type Selector added in v0.1.1 

type Selector struct {
	Aggregate []string `protobuf:"bytes,1,rep,name=aggregate,proto3" json:"aggregate,omitempty"`
	Type      string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func SelectorToProto added in v0.1.1 

func SelectorToProto(s *es.Selector) *Selector

func (*Selector) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use Selector.ProtoReflect.Descriptor instead.

func (*Selector) GetAggregate added in v0.1.1 

func (x *Selector) GetAggregate() []string

func (*Selector) GetType added in v0.1.1 

func (x *Selector) GetType() string

func (*Selector) ProtoMessage added in v0.1.1 

func (*Selector) ProtoMessage()

func (*Selector) ProtoReflect added in v0.1.1 

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

func (*Selector) Reset added in v0.1.1 

func (x *Selector) Reset()

func (*Selector) String added in v0.1.1 

func (x *Selector) String() string

type ServerState added in v0.1.1 

type ServerState struct {
	Uptime          int64  `protobuf:"varint,1,opt,name=uptime,proto3" json:"uptime,omitempty"`
	ConnectionCount uint32 `protobuf:"varint,2,opt,name=connection_count,json=connectionCount,proto3" json:"connection_count,omitempty"`
	EventCount      int64  `protobuf:"varint,3,opt,name=event_count,json=eventCount,proto3" json:"event_count,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerState) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ServerState.ProtoReflect.Descriptor instead.

func (*ServerState) GetConnectionCount added in v0.1.1 

func (x *ServerState) GetConnectionCount() uint32

func (*ServerState) GetEventCount added in v0.1.1 

func (x *ServerState) GetEventCount() int64

func (*ServerState) GetUptime added in v0.1.1 

func (x *ServerState) GetUptime() int64

func (*ServerState) ProtoMessage added in v0.1.1 

func (*ServerState) ProtoMessage()

func (*ServerState) ProtoReflect added in v0.1.1 

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

func (*ServerState) Reset added in v0.1.1 

func (x *ServerState) Reset()

func (*ServerState) String added in v0.1.1 

func (x *ServerState) String() string

type ShutdownParameters added in v0.1.1 

type ShutdownParameters struct {
	GracePeriod uint32 `protobuf:"varint,1,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownParameters) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ShutdownParameters.ProtoReflect.Descriptor instead.

func (*ShutdownParameters) GetGracePeriod added in v0.1.1 

func (x *ShutdownParameters) GetGracePeriod() uint32

func (*ShutdownParameters) ProtoMessage added in v0.1.1 

func (*ShutdownParameters) ProtoMessage()

func (*ShutdownParameters) ProtoReflect added in v0.1.1 

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

func (*ShutdownParameters) Reset added in v0.1.1 

func (x *ShutdownParameters) Reset()

func (*ShutdownParameters) String added in v0.1.1 

func (x *ShutdownParameters) String() string

type StreamRequest added in v0.1.1 

type StreamRequest struct {
	Bracket  *Bracket  `protobuf:"bytes,1,opt,name=bracket,proto3" json:"bracket,omitempty"`
	Selector *Selector `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetBracket added in v0.1.1 

func (x *StreamRequest) GetBracket() *Bracket

func (*StreamRequest) GetSelector added in v0.1.1 

func (x *StreamRequest) GetSelector() *Selector

func (*StreamRequest) ProtoMessage added in v0.1.1 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect added in v0.1.1 

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

func (*StreamRequest) Reset added in v0.1.1 

func (x *StreamRequest) Reset()

func (*StreamRequest) String added in v0.1.1 

func (x *StreamRequest) String() string

type SubscriptionRequest added in v0.1.1 

type SubscriptionRequest struct {
	PersistentClientId string `protobuf:"bytes,1,opt,name=persistent_client_id,json=persistentClientId,proto3" json:"persistent_client_id,omitempty"`
	//  Bracket bracket = 2;
	Selector *Selector `protobuf:"bytes,3,opt,name=selector,proto3" json:"selector,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionRequest) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionRequest) GetPersistentClientId added in v0.1.1 

func (x *SubscriptionRequest) GetPersistentClientId() string

func (*SubscriptionRequest) GetSelector added in v0.1.1 

func (x *SubscriptionRequest) GetSelector() *Selector

func (*SubscriptionRequest) ProtoMessage added in v0.1.1 

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) ProtoReflect added in v0.1.1 

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

func (*SubscriptionRequest) Reset added in v0.1.1 

func (x *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String added in v0.1.1 

func (x *SubscriptionRequest) String() string

type SubscriptionState added in v0.1.6 

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

func (*SubscriptionState) Descriptor deprecated added in v0.1.6 

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

Deprecated: Use SubscriptionState.ProtoReflect.Descriptor instead.

func (*SubscriptionState) ProtoMessage added in v0.1.6 

func (*SubscriptionState) ProtoMessage()

func (*SubscriptionState) ProtoReflect added in v0.1.6 

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

func (*SubscriptionState) Reset added in v0.1.6 

func (x *SubscriptionState) Reset()

func (*SubscriptionState) String added in v0.1.6 

func (x *SubscriptionState) String() string

type SubscriptionsRequest added in v0.1.6 

type SubscriptionsRequest struct {
	ClientIDPattern *string `protobuf:"bytes,1,opt,name=clientIDPattern,proto3,oneof" json:"clientIDPattern,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionsRequest) Descriptor deprecated added in v0.1.6 

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

Deprecated: Use SubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionsRequest) GetClientIDPattern added in v0.1.6 

func (x *SubscriptionsRequest) GetClientIDPattern() string

func (*SubscriptionsRequest) ProtoMessage added in v0.1.6 

func (*SubscriptionsRequest) ProtoMessage()

func (*SubscriptionsRequest) ProtoReflect added in v0.1.6 

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

func (*SubscriptionsRequest) Reset added in v0.1.6 

func (x *SubscriptionsRequest) Reset()

func (*SubscriptionsRequest) String added in v0.1.6 

func (x *SubscriptionsRequest) String() string

type SubscriptionsResponse added in v0.1.6 

type SubscriptionsResponse struct {
	Subscriptions []*SubscriptionState `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionsResponse) Descriptor deprecated added in v0.1.6 

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

Deprecated: Use SubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*SubscriptionsResponse) GetSubscriptions added in v0.1.6 

func (x *SubscriptionsResponse) GetSubscriptions() []*SubscriptionState

func (*SubscriptionsResponse) ProtoMessage added in v0.1.6 

func (*SubscriptionsResponse) ProtoMessage()

func (*SubscriptionsResponse) ProtoReflect added in v0.1.6 

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

func (*SubscriptionsResponse) Reset added in v0.1.6 

func (x *SubscriptionsResponse) Reset()

func (*SubscriptionsResponse) String added in v0.1.6 

func (x *SubscriptionsResponse) String() string

type UnimplementedEventStreamServer added in v0.1.1 

type UnimplementedEventStreamServer struct {
}

UnimplementedEventStreamServer must be embedded to have forward compatible implementations.

func (UnimplementedEventStreamServer) Acknowledge added in v0.1.1 

func (UnimplementedEventStreamServer) Acknowledge(EventStream_AcknowledgeServer) error

func (UnimplementedEventStreamServer) Emit added in v0.1.1 

func (UnimplementedEventStreamServer) Emit(context.Context, *Event) (*Published, error)

func (UnimplementedEventStreamServer) Listen added in v0.1.5 

func (UnimplementedEventStreamServer) Listen(*ListenRequest, EventStream_ListenServer) error

func (UnimplementedEventStreamServer) Stream added in v0.1.1 

func (UnimplementedEventStreamServer) Stream(*StreamRequest, EventStream_StreamServer) error

func (UnimplementedEventStreamServer) Subscribe added in v0.1.1 

func (UnimplementedEventStreamServer) Subscribe(*SubscriptionRequest, EventStream_SubscribeServer) error

type UnimplementedMaintenanceServer added in v0.1.1 

type UnimplementedMaintenanceServer struct {
}

UnimplementedMaintenanceServer must be embedded to have forward compatible implementations.

func (UnimplementedMaintenanceServer) GetServerState added in v0.1.1 

func (UnimplementedMaintenanceServer) GetServerState(context.Context, *emptypb.Empty) (*ServerState, error)

func (UnimplementedMaintenanceServer) GetSubscriptions added in v0.1.6 

func (UnimplementedMaintenanceServer) GetSubscriptions(context.Context, *SubscriptionsRequest) (*SubscriptionsResponse, error)

func (UnimplementedMaintenanceServer) Shutdown added in v0.1.1 

func (UnimplementedMaintenanceServer) Shutdown(context.Context, *ShutdownParameters) (*emptypb.Empty, error)

type UnsafeEventStreamServer added in v0.1.1 

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

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

type UnsafeMaintenanceServer added in v0.1.1 

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

UnsafeMaintenanceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MaintenanceServer 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.