pbserverdiscovery

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2024 License: MPL-2.0 Imports: 11 Imported by: 1

Documentation

Overview

Code generated by protoc-gen-deepcopy. DO NOT EDIT.

Code generated by protoc-json-shim. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ServerdiscoveryMarshaler   = &protojson.MarshalOptions{}
	ServerdiscoveryUnmarshaler = &protojson.UnmarshalOptions{DiscardUnknown: false}
)
View Source 
var File_pbserverdiscovery_serverdiscovery_proto protoreflect.FileDescriptor
View Source 
var ServerDiscoveryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hashicorp.consul.serverdiscovery.ServerDiscoveryService",
	HandlerType: (*ServerDiscoveryServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchServers",
			Handler:       _ServerDiscoveryService_WatchServers_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pbserverdiscovery/serverdiscovery.proto",
}

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

Functions

func RegisterServerDiscoveryServiceServer 

func RegisterServerDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ServerDiscoveryServiceServer)

Types

type CloningServerDiscoveryServiceClient added in v0.6.0 

type CloningServerDiscoveryServiceClient struct {
	ServerDiscoveryServiceClient
}

CloningServerDiscoveryServiceClient implements the ServerDiscoveryServiceClient interface by wrapping another implementation and copying all protobuf messages that pass through the client. This is mainly useful to wrap the an in-process client to insulate users of that client from having to care about potential immutability of data they receive or having the server implementation mutate their internal memory.

func (CloningServerDiscoveryServiceClient) IsCloningServerDiscoveryServiceClient added in v0.6.0 

func (c CloningServerDiscoveryServiceClient) IsCloningServerDiscoveryServiceClient() bool

IsCloningServerDiscoveryServiceClient implements the IsCloningServerDiscoveryServiceClient interface. This is only used to detect wrapped clients that would be double cloning data and prevent that.

func (CloningServerDiscoveryServiceClient) WatchServers added in v0.6.0 

func (c CloningServerDiscoveryServiceClient) WatchServers(ctx context.Context, in *WatchServersRequest, opts ...grpc.CallOption) (ServerDiscoveryService_WatchServersClient, error)

type IsCloningServerDiscoveryServiceClient added in v0.6.0 

type IsCloningServerDiscoveryServiceClient interface {
	IsCloningServerDiscoveryServiceClient() bool
}

IsCloningServerDiscoveryServiceClient is an interface that can be used to detect that a ServerDiscoveryServiceClient is using the in-memory transport and has already been wrapped with a with a CloningServerDiscoveryServiceClient.

type Server 

type Server struct {

	// id is the unique string identifying this server for all time.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// address on the network of the server
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// the consul version of the server
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Server) DeepCopy added in v0.5.1 

func (in *Server) DeepCopy() *Server

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Server. Required by controller-gen.

func (*Server) DeepCopyInterface added in v0.5.1 

func (in *Server) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Server. Required by controller-gen.

func (*Server) DeepCopyInto added in v0.5.1 

func (in *Server) DeepCopyInto(out *Server)

DeepCopyInto supports using Server within kubernetes types, where deepcopy-gen is used.

func (*Server) Descriptor deprecated 

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

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetAddress 

func (x *Server) GetAddress() string

func (*Server) GetId 

func (x *Server) GetId() string

func (*Server) GetVersion 

func (x *Server) GetVersion() string

func (*Server) MarshalBinary 

func (msg *Server) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Server) MarshalJSON added in v0.5.1 

func (this *Server) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Server

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect 

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

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) String 

func (x *Server) String() string

func (*Server) UnmarshalBinary 

func (msg *Server) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*Server) UnmarshalJSON added in v0.5.1 

func (this *Server) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Server

type ServerDiscoveryServiceClient 

type ServerDiscoveryServiceClient interface {
	// WatchServers will stream back sets of ready servers as they change such as
	// when new servers are added or older ones removed. A ready server is one that
	// should be considered ready for sending general RPC requests towards that would
	// catalog queries, xDS proxy configurations and similar services.
	WatchServers(ctx context.Context, in *WatchServersRequest, opts ...grpc.CallOption) (ServerDiscoveryService_WatchServersClient, error)
}

ServerDiscoveryServiceClient is the client API for ServerDiscoveryService 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 NewCloningServerDiscoveryServiceClient added in v0.6.0 

func NewCloningServerDiscoveryServiceClient(client ServerDiscoveryServiceClient) ServerDiscoveryServiceClient

func NewServerDiscoveryServiceClient 

func NewServerDiscoveryServiceClient(cc grpc.ClientConnInterface) ServerDiscoveryServiceClient

type ServerDiscoveryServiceServer 

type ServerDiscoveryServiceServer interface {
	// WatchServers will stream back sets of ready servers as they change such as
	// when new servers are added or older ones removed. A ready server is one that
	// should be considered ready for sending general RPC requests towards that would
	// catalog queries, xDS proxy configurations and similar services.
	WatchServers(*WatchServersRequest, ServerDiscoveryService_WatchServersServer) error
}

ServerDiscoveryServiceServer is the server API for ServerDiscoveryService service. All implementations should embed UnimplementedServerDiscoveryServiceServer for forward compatibility

type ServerDiscoveryService_WatchServersClient 

type ServerDiscoveryService_WatchServersClient interface {
	Recv() (*WatchServersResponse, error)
	grpc.ClientStream
}

type ServerDiscoveryService_WatchServersServer 

type ServerDiscoveryService_WatchServersServer interface {
	Send(*WatchServersResponse) error
	grpc.ServerStream
}

type UnimplementedServerDiscoveryServiceServer 

type UnimplementedServerDiscoveryServiceServer struct {
}

UnimplementedServerDiscoveryServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedServerDiscoveryServiceServer) WatchServers 

func (UnimplementedServerDiscoveryServiceServer) WatchServers(*WatchServersRequest, ServerDiscoveryService_WatchServersServer) error

type UnsafeServerDiscoveryServiceServer 

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

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

type WatchServersRequest 

type WatchServersRequest struct {

	// Wan being set to true will cause WAN addresses to be sent in the response
	// instead of the LAN addresses which are the default
	Wan bool `protobuf:"varint,1,opt,name=wan,proto3" json:"wan,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchServersRequest) DeepCopy added in v0.5.1 

func (in *WatchServersRequest) DeepCopy() *WatchServersRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchServersRequest. Required by controller-gen.

func (*WatchServersRequest) DeepCopyInterface added in v0.5.1 

func (in *WatchServersRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WatchServersRequest. Required by controller-gen.

func (*WatchServersRequest) DeepCopyInto added in v0.5.1 

func (in *WatchServersRequest) DeepCopyInto(out *WatchServersRequest)

DeepCopyInto supports using WatchServersRequest within kubernetes types, where deepcopy-gen is used.

func (*WatchServersRequest) Descriptor deprecated 

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

Deprecated: Use WatchServersRequest.ProtoReflect.Descriptor instead.

func (*WatchServersRequest) GetWan 

func (x *WatchServersRequest) GetWan() bool

func (*WatchServersRequest) MarshalBinary 

func (msg *WatchServersRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WatchServersRequest) MarshalJSON added in v0.5.1 

func (this *WatchServersRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WatchServersRequest

func (*WatchServersRequest) ProtoMessage 

func (*WatchServersRequest) ProtoMessage()

func (*WatchServersRequest) ProtoReflect 

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

func (*WatchServersRequest) Reset 

func (x *WatchServersRequest) Reset()

func (*WatchServersRequest) String 

func (x *WatchServersRequest) String() string

func (*WatchServersRequest) UnmarshalBinary 

func (msg *WatchServersRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WatchServersRequest) UnmarshalJSON added in v0.5.1 

func (this *WatchServersRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WatchServersRequest

type WatchServersResponse 

type WatchServersResponse struct {

	// Servers is the list of server address information.
	Servers []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchServersResponse) DeepCopy added in v0.5.1 

func (in *WatchServersResponse) DeepCopy() *WatchServersResponse

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchServersResponse. Required by controller-gen.

func (*WatchServersResponse) DeepCopyInterface added in v0.5.1 

func (in *WatchServersResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WatchServersResponse. Required by controller-gen.

func (*WatchServersResponse) DeepCopyInto added in v0.5.1 

func (in *WatchServersResponse) DeepCopyInto(out *WatchServersResponse)

DeepCopyInto supports using WatchServersResponse within kubernetes types, where deepcopy-gen is used.

func (*WatchServersResponse) Descriptor deprecated 

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

Deprecated: Use WatchServersResponse.ProtoReflect.Descriptor instead.

func (*WatchServersResponse) GetServers 

func (x *WatchServersResponse) GetServers() []*Server

func (*WatchServersResponse) MarshalBinary 

func (msg *WatchServersResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*WatchServersResponse) MarshalJSON added in v0.5.1 

func (this *WatchServersResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for WatchServersResponse

func (*WatchServersResponse) ProtoMessage 

func (*WatchServersResponse) ProtoMessage()

func (*WatchServersResponse) ProtoReflect 

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

func (*WatchServersResponse) Reset 

func (x *WatchServersResponse) Reset()

func (*WatchServersResponse) String 

func (x *WatchServersResponse) String() string

func (*WatchServersResponse) UnmarshalBinary 

func (msg *WatchServersResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

func (*WatchServersResponse) UnmarshalJSON added in v0.5.1 

func (this *WatchServersResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for WatchServersResponse

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.