endpointupdater

Documentation

Index

• Variables
• func RegisterTestUpdaterServer(s grpc.ServiceRegistrar, srv TestUpdaterServer)
• type Endpoint
  • func (*Endpoint) Descriptor() ([]byte, []int)
  • func (x *Endpoint) GetIpAddress() string
  • func (x *Endpoint) GetPort() uint32
  • func (*Endpoint) ProtoMessage()
  • func (x *Endpoint) ProtoReflect() protoreflect.Message
  • func (x *Endpoint) Reset()
  • func (x *Endpoint) String() string
• type TestUpdateReply
  • func (*TestUpdateReply) Descriptor() ([]byte, []int)
  • func (x *TestUpdateReply) GetPsmServerTargetOverride() string
  • func (*TestUpdateReply) ProtoMessage()
  • func (x *TestUpdateReply) ProtoReflect() protoreflect.Message
  • func (x *TestUpdateReply) Reset()
  • func (x *TestUpdateReply) String() string
• type TestUpdateRequest
  • func (*TestUpdateRequest) Descriptor() ([]byte, []int)
  • func (x *TestUpdateRequest) GetEndpoints() []*Endpoint
  • func (x *TestUpdateRequest) GetIsProxied() bool
  • func (*TestUpdateRequest) ProtoMessage()
  • func (x *TestUpdateRequest) ProtoReflect() protoreflect.Message
  • func (x *TestUpdateRequest) Reset()
  • func (x *TestUpdateRequest) String() string
• type TestUpdaterClient
  • func NewTestUpdaterClient(cc grpc.ClientConnInterface) TestUpdaterClient
• type TestUpdaterServer
• type UnimplementedTestUpdaterServer
  • func (UnimplementedTestUpdaterServer) QuitTestUpdateServer(context.Context, *Void) (*Void, error)
  • func (UnimplementedTestUpdaterServer) UpdateTest(context.Context, *TestUpdateRequest) (*TestUpdateReply, error)
• type UnsafeTestUpdaterServer
• type Void
  • func (*Void) Descriptor() ([]byte, []int)
  • func (*Void) ProtoMessage()
  • func (x *Void) ProtoReflect() protoreflect.Message
  • func (x *Void) Reset()
  • func (x *Void) String() string

Variables

var File_endpoint_proto protoreflect.FileDescriptor

var TestUpdater_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "endpointupdater.TestUpdater",
	HandlerType: (*TestUpdaterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateTest",
			Handler:    _TestUpdater_UpdateTest_Handler,
		},
		{
			MethodName: "QuitTestUpdateServer",
			Handler:    _TestUpdater_QuitTestUpdateServer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "endpoint.proto",
}

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

Functions

func RegisterTestUpdaterServer

func RegisterTestUpdaterServer(s grpc.ServiceRegistrar, srv TestUpdaterServer)

Types

type Endpoint

type Endpoint struct {
	IpAddress string `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	Port      uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetIpAddress

func (x *Endpoint) GetIpAddress() string

func (*Endpoint) GetPort

func (x *Endpoint) GetPort() uint32

func (*Endpoint) ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect

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

func (*Endpoint) Reset

func (x *Endpoint) Reset()

func (*Endpoint) String

func (x *Endpoint) String() string

type TestUpdateReply

type TestUpdateReply struct {
	PsmServerTargetOverride string `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TestUpdateReply) Descriptor

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

Deprecated: Use TestUpdateReply.ProtoReflect.Descriptor instead.

func (*TestUpdateReply) GetPsmServerTargetOverride

func (x *TestUpdateReply) GetPsmServerTargetOverride() string

func (*TestUpdateReply) ProtoMessage

func (*TestUpdateReply) ProtoMessage()

func (*TestUpdateReply) ProtoReflect

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

func (*TestUpdateReply) Reset

func (x *TestUpdateReply) Reset()

func (*TestUpdateReply) String

func (x *TestUpdateReply) String() string

type TestUpdateRequest

type TestUpdateRequest struct {
	Endpoints []*Endpoint `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	IsProxied bool        `protobuf:"varint,2,opt,name=is_proxied,json=isProxied,proto3" json:"is_proxied,omitempty"`
	// contains filtered or unexported fields
}

func (*TestUpdateRequest) Descriptor

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

Deprecated: Use TestUpdateRequest.ProtoReflect.Descriptor instead.

func (*TestUpdateRequest) GetEndpoints

func (x *TestUpdateRequest) GetEndpoints() []*Endpoint

func (*TestUpdateRequest) GetIsProxied

func (x *TestUpdateRequest) GetIsProxied() bool

func (*TestUpdateRequest) ProtoMessage

func (*TestUpdateRequest) ProtoMessage()

func (*TestUpdateRequest) ProtoReflect

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

func (*TestUpdateRequest) Reset

func (x *TestUpdateRequest) Reset()

func (*TestUpdateRequest) String

func (x *TestUpdateRequest) String() string

type TestUpdaterClient

type TestUpdaterClient interface {
	// Sends an update
	UpdateTest(ctx context.Context, in *TestUpdateRequest, opts ...grpc.CallOption) (*TestUpdateReply, error)
	QuitTestUpdateServer(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error)
}

TestUpdaterClient is the client API for TestUpdater 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 NewTestUpdaterClient

func NewTestUpdaterClient(cc grpc.ClientConnInterface) TestUpdaterClient

type TestUpdaterServer

type TestUpdaterServer interface {
	// Sends an update
	UpdateTest(context.Context, *TestUpdateRequest) (*TestUpdateReply, error)
	QuitTestUpdateServer(context.Context, *Void) (*Void, error)
	// contains filtered or unexported methods
}

TestUpdaterServer is the server API for TestUpdater service. All implementations must embed UnimplementedTestUpdaterServer for forward compatibility

type UnimplementedTestUpdaterServer

type UnimplementedTestUpdaterServer struct {
}

UnimplementedTestUpdaterServer must be embedded to have forward compatible implementations.

func (UnimplementedTestUpdaterServer) QuitTestUpdateServer

func (UnimplementedTestUpdaterServer) QuitTestUpdateServer(context.Context, *Void) (*Void, error)

func (UnimplementedTestUpdaterServer) UpdateTest

func (UnimplementedTestUpdaterServer) UpdateTest(context.Context, *TestUpdateRequest) (*TestUpdateReply, error)

type UnsafeTestUpdaterServer

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

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

type Void

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

func (*Void) Descriptor

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) ProtoReflect

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

func (*Void) Reset

func (x *Void) Reset()

func (*Void) String

func (x *Void) String() string