proto

Documentation

Index

• Variables
• func RegisterMetaMemberServiceServer(s grpc.ServiceRegistrar, srv MetaMemberServiceServer)
• type HostAddress
  • func (*HostAddress) Descriptor() ([]byte, []int)
  • func (x *HostAddress) GetHost() string
  • func (x *HostAddress) GetPort() int32
  • func (*HostAddress) ProtoMessage()
  • func (x *HostAddress) ProtoReflect() protoreflect.Message
  • func (x *HostAddress) Reset()
  • func (x *HostAddress) String() string
• type MembersRequest
  • func (*MembersRequest) Descriptor() ([]byte, []int)
  • func (*MembersRequest) ProtoMessage()
  • func (x *MembersRequest) ProtoReflect() protoreflect.Message
  • func (x *MembersRequest) Reset()
  • func (x *MembersRequest) String() string
• type MembersResponse
  • func (*MembersResponse) Descriptor() ([]byte, []int)
  • func (x *MembersResponse) GetMembers() []*MetaMember
  • func (*MembersResponse) ProtoMessage()
  • func (x *MembersResponse) ProtoReflect() protoreflect.Message
  • func (x *MembersResponse) Reset()
  • func (x *MembersResponse) String() string
• type MetaMember
  • func (*MetaMember) Descriptor() ([]byte, []int)
  • func (x *MetaMember) GetAddress() *HostAddress
  • func (x *MetaMember) GetIsLeader() bool
  • func (*MetaMember) ProtoMessage()
  • func (x *MetaMember) ProtoReflect() protoreflect.Message
  • func (x *MetaMember) Reset()
  • func (x *MetaMember) String() string
• type MetaMemberServiceClient
  • func NewMetaMemberServiceClient(cc grpc.ClientConnInterface) MetaMemberServiceClient
• type MetaMemberServiceServer
• type UnimplementedMetaMemberServiceServer
  • func (UnimplementedMetaMemberServiceServer) Members(context.Context, *MembersRequest) (*MembersResponse, error)
• type UnsafeMetaMemberServiceServer

Variables

var File_common_proto protoreflect.FileDescriptor

var File_meta_proto protoreflect.FileDescriptor

var MetaMemberService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "meta.MetaMemberService",
	HandlerType: (*MetaMemberServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Members",
			Handler:    _MetaMemberService_Members_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "meta.proto",
}

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

Functions

func RegisterMetaMemberServiceServer

func RegisterMetaMemberServiceServer(s grpc.ServiceRegistrar, srv MetaMemberServiceServer)

Types

type HostAddress

type HostAddress struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*HostAddress) Descriptor

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

Deprecated: Use HostAddress.ProtoReflect.Descriptor instead.

func (*HostAddress) GetHost

func (x *HostAddress) GetHost() string

func (*HostAddress) GetPort

func (x *HostAddress) GetPort() int32

func (*HostAddress) ProtoMessage

func (*HostAddress) ProtoMessage()

func (*HostAddress) ProtoReflect

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

func (*HostAddress) Reset

func (x *HostAddress) Reset()

func (*HostAddress) String

func (x *HostAddress) String() string

type MembersRequest

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

func (*MembersRequest) Descriptor

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

Deprecated: Use MembersRequest.ProtoReflect.Descriptor instead.

func (*MembersRequest) ProtoMessage

func (*MembersRequest) ProtoMessage()

func (*MembersRequest) ProtoReflect

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

func (*MembersRequest) Reset

func (x *MembersRequest) Reset()

func (*MembersRequest) String

func (x *MembersRequest) String() string

type MembersResponse

type MembersResponse struct {
	Members []*MetaMember `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*MembersResponse) Descriptor

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

Deprecated: Use MembersResponse.ProtoReflect.Descriptor instead.

func (*MembersResponse) GetMembers

func (x *MembersResponse) GetMembers() []*MetaMember

func (*MembersResponse) ProtoMessage

func (*MembersResponse) ProtoMessage()

func (*MembersResponse) ProtoReflect

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

func (*MembersResponse) Reset

func (x *MembersResponse) Reset()

func (*MembersResponse) String

func (x *MembersResponse) String() string

type MetaMember

type MetaMember struct {
	Address  *HostAddress `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	IsLeader bool         `protobuf:"varint,2,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaMember) Descriptor

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

Deprecated: Use MetaMember.ProtoReflect.Descriptor instead.

func (*MetaMember) GetAddress

func (x *MetaMember) GetAddress() *HostAddress

func (*MetaMember) GetIsLeader

func (x *MetaMember) GetIsLeader() bool

func (*MetaMember) ProtoMessage

func (*MetaMember) ProtoMessage()

func (*MetaMember) ProtoReflect

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

func (*MetaMember) Reset

func (x *MetaMember) Reset()

func (*MetaMember) String

func (x *MetaMember) String() string

type MetaMemberServiceClient

type MetaMemberServiceClient interface {
	Members(ctx context.Context, in *MembersRequest, opts ...grpc.CallOption) (*MembersResponse, error)
}

MetaMemberServiceClient is the client API for MetaMemberService 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 NewMetaMemberServiceClient

func NewMetaMemberServiceClient(cc grpc.ClientConnInterface) MetaMemberServiceClient

type MetaMemberServiceServer

type MetaMemberServiceServer interface {
	Members(context.Context, *MembersRequest) (*MembersResponse, error)
	// contains filtered or unexported methods
}

MetaMemberServiceServer is the server API for MetaMemberService service. All implementations must embed UnimplementedMetaMemberServiceServer for forward compatibility

type UnimplementedMetaMemberServiceServer

type UnimplementedMetaMemberServiceServer struct {
}

UnimplementedMetaMemberServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetaMemberServiceServer) Members

func (UnimplementedMetaMemberServiceServer) Members(context.Context, *MembersRequest) (*MembersResponse, error)

type UnsafeMetaMemberServiceServer

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

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