pb

package

Go to main page

Versions in this module

v0

v0.1.5

Oct 22, 2024

v0.1.4

Mar 12, 2024

Changes in this version

type Affiliate

+ func (m *Affiliate) CloneMessageVT() proto.Message

+ func (m *Affiliate) CloneVT() *Affiliate

type AffiliateDeleteRequest

+ func (m *AffiliateDeleteRequest) CloneMessageVT() proto.Message

+ func (m *AffiliateDeleteRequest) CloneVT() *AffiliateDeleteRequest

type AffiliateDeleteResponse

+ func (m *AffiliateDeleteResponse) CloneMessageVT() proto.Message

+ func (m *AffiliateDeleteResponse) CloneVT() *AffiliateDeleteResponse

type AffiliateUpdateRequest

+ func (m *AffiliateUpdateRequest) CloneMessageVT() proto.Message

+ func (m *AffiliateUpdateRequest) CloneVT() *AffiliateUpdateRequest

type AffiliateUpdateResponse

+ func (m *AffiliateUpdateResponse) CloneMessageVT() proto.Message

+ func (m *AffiliateUpdateResponse) CloneVT() *AffiliateUpdateResponse

type HelloRequest

+ func (m *HelloRequest) CloneMessageVT() proto.Message

+ func (m *HelloRequest) CloneVT() *HelloRequest

type HelloResponse

+ func (m *HelloResponse) CloneMessageVT() proto.Message

+ func (m *HelloResponse) CloneVT() *HelloResponse

type ListRequest

+ func (m *ListRequest) CloneMessageVT() proto.Message

+ func (m *ListRequest) CloneVT() *ListRequest

type ListResponse

+ func (m *ListResponse) CloneMessageVT() proto.Message

+ func (m *ListResponse) CloneVT() *ListResponse

type RedirectMessage

+ func (m *RedirectMessage) CloneMessageVT() proto.Message

+ func (m *RedirectMessage) CloneVT() *RedirectMessage

type WatchRequest

+ func (m *WatchRequest) CloneMessageVT() proto.Message

+ func (m *WatchRequest) CloneVT() *WatchRequest

type WatchResponse

+ func (m *WatchResponse) CloneMessageVT() proto.Message

+ func (m *WatchResponse) CloneVT() *WatchResponse

v0.1.3

Jun 1, 2023

Changes in this version

+ const Cluster_AffiliateDelete_FullMethodName

+ const Cluster_AffiliateUpdate_FullMethodName

+ const Cluster_Hello_FullMethodName

+ const Cluster_List_FullMethodName

+ const Cluster_Watch_FullMethodName

v0.1.2

Jan 30, 2023

Changes in this version

type Affiliate

+ func (this *Affiliate) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *Affiliate) EqualVT(that *Affiliate) bool

type AffiliateDeleteRequest

+ func (this *AffiliateDeleteRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *AffiliateDeleteRequest) EqualVT(that *AffiliateDeleteRequest) bool

type AffiliateDeleteResponse

+ func (this *AffiliateDeleteResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *AffiliateDeleteResponse) EqualVT(that *AffiliateDeleteResponse) bool

type AffiliateUpdateRequest

+ func (this *AffiliateUpdateRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *AffiliateUpdateRequest) EqualVT(that *AffiliateUpdateRequest) bool

type AffiliateUpdateResponse

+ func (this *AffiliateUpdateResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *AffiliateUpdateResponse) EqualVT(that *AffiliateUpdateResponse) bool

type HelloRequest

+ func (this *HelloRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *HelloRequest) EqualVT(that *HelloRequest) bool

type HelloResponse

+ func (this *HelloResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *HelloResponse) EqualVT(that *HelloResponse) bool

type ListRequest

+ func (this *ListRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ListRequest) EqualVT(that *ListRequest) bool

type ListResponse

+ func (this *ListResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *ListResponse) EqualVT(that *ListResponse) bool

type RedirectMessage

+ func (this *RedirectMessage) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *RedirectMessage) EqualVT(that *RedirectMessage) bool

type WatchRequest

+ func (this *WatchRequest) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *WatchRequest) EqualVT(that *WatchRequest) bool

type WatchResponse

+ func (this *WatchResponse) EqualMessageVT(thatMsg proto.Message) bool

+ func (this *WatchResponse) EqualVT(that *WatchResponse) bool

v0.1.1

Sep 15, 2022

Changes in this version

+ var Cluster_ServiceDesc = grpc.ServiceDesc

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_v1alpha1_server_pb_cluster_proto protoreflect.FileDescriptor

+ func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

+ type Affiliate struct

+ Data []byte

+ Endpoints [][]byte

+ Id string

+ func (*Affiliate) Descriptor() ([]byte, []int)

+ func (*Affiliate) ProtoMessage()

+ func (m *Affiliate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Affiliate) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Affiliate) MarshalVT() (dAtA []byte, err error)

+ func (m *Affiliate) SizeVT() (n int)

+ func (m *Affiliate) UnmarshalVT(dAtA []byte) error

+ func (x *Affiliate) GetData() []byte

+ func (x *Affiliate) GetEndpoints() [][]byte

+ func (x *Affiliate) GetId() string

+ func (x *Affiliate) ProtoReflect() protoreflect.Message

+ func (x *Affiliate) Reset()

+ func (x *Affiliate) String() string

+ type AffiliateDeleteRequest struct

+ AffiliateId string

+ ClusterId string

+ func (*AffiliateDeleteRequest) Descriptor() ([]byte, []int)

+ func (*AffiliateDeleteRequest) ProtoMessage()

+ func (m *AffiliateDeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *AffiliateDeleteRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *AffiliateDeleteRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *AffiliateDeleteRequest) SizeVT() (n int)

+ func (m *AffiliateDeleteRequest) UnmarshalVT(dAtA []byte) error

+ func (x *AffiliateDeleteRequest) GetAffiliateId() string

+ func (x *AffiliateDeleteRequest) GetClusterId() string

+ func (x *AffiliateDeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *AffiliateDeleteRequest) Reset()

+ func (x *AffiliateDeleteRequest) String() string

+ type AffiliateDeleteResponse struct

+ func (*AffiliateDeleteResponse) Descriptor() ([]byte, []int)

+ func (*AffiliateDeleteResponse) ProtoMessage()

+ func (m *AffiliateDeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *AffiliateDeleteResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *AffiliateDeleteResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *AffiliateDeleteResponse) SizeVT() (n int)

+ func (m *AffiliateDeleteResponse) UnmarshalVT(dAtA []byte) error

+ func (x *AffiliateDeleteResponse) ProtoReflect() protoreflect.Message

+ func (x *AffiliateDeleteResponse) Reset()

+ func (x *AffiliateDeleteResponse) String() string

+ type AffiliateUpdateRequest struct

+ AffiliateData []byte

+ AffiliateEndpoints [][]byte

+ AffiliateId string

+ ClusterId string

+ Ttl *durationpb.Duration

+ func (*AffiliateUpdateRequest) Descriptor() ([]byte, []int)

+ func (*AffiliateUpdateRequest) ProtoMessage()

+ func (m *AffiliateUpdateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *AffiliateUpdateRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *AffiliateUpdateRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *AffiliateUpdateRequest) SizeVT() (n int)

+ func (m *AffiliateUpdateRequest) UnmarshalVT(dAtA []byte) error

+ func (x *AffiliateUpdateRequest) GetAffiliateData() []byte

+ func (x *AffiliateUpdateRequest) GetAffiliateEndpoints() [][]byte

+ func (x *AffiliateUpdateRequest) GetAffiliateId() string

+ func (x *AffiliateUpdateRequest) GetClusterId() string

+ func (x *AffiliateUpdateRequest) GetTtl() *durationpb.Duration

+ func (x *AffiliateUpdateRequest) ProtoReflect() protoreflect.Message

+ func (x *AffiliateUpdateRequest) Reset()

+ func (x *AffiliateUpdateRequest) String() string

+ type AffiliateUpdateResponse struct

+ func (*AffiliateUpdateResponse) Descriptor() ([]byte, []int)

+ func (*AffiliateUpdateResponse) ProtoMessage()

+ func (m *AffiliateUpdateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *AffiliateUpdateResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *AffiliateUpdateResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *AffiliateUpdateResponse) SizeVT() (n int)

+ func (m *AffiliateUpdateResponse) UnmarshalVT(dAtA []byte) error

+ func (x *AffiliateUpdateResponse) ProtoReflect() protoreflect.Message

+ func (x *AffiliateUpdateResponse) Reset()

+ func (x *AffiliateUpdateResponse) String() string

+ type ClusterClient interface

+ AffiliateDelete func(ctx context.Context, in *AffiliateDeleteRequest, opts ...grpc.CallOption) (*AffiliateDeleteResponse, error)

+ AffiliateUpdate func(ctx context.Context, in *AffiliateUpdateRequest, opts ...grpc.CallOption) (*AffiliateUpdateResponse, error)

+ Hello func(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)

+ Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Cluster_WatchClient, error)

+ func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

+ type ClusterServer interface

+ AffiliateDelete func(context.Context, *AffiliateDeleteRequest) (*AffiliateDeleteResponse, error)

+ AffiliateUpdate func(context.Context, *AffiliateUpdateRequest) (*AffiliateUpdateResponse, error)

+ Hello func(context.Context, *HelloRequest) (*HelloResponse, error)

+ List func(context.Context, *ListRequest) (*ListResponse, error)

+ Watch func(*WatchRequest, Cluster_WatchServer) error

+ type Cluster_WatchClient interface

+ Recv func() (*WatchResponse, error)

+ type Cluster_WatchServer interface

+ Send func(*WatchResponse) error

+ type HelloRequest struct

+ ClientVersion string

+ ClusterId string

+ func (*HelloRequest) Descriptor() ([]byte, []int)

+ func (*HelloRequest) ProtoMessage()

+ func (m *HelloRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *HelloRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *HelloRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *HelloRequest) SizeVT() (n int)

+ func (m *HelloRequest) UnmarshalVT(dAtA []byte) error

+ func (x *HelloRequest) GetClientVersion() string

+ func (x *HelloRequest) GetClusterId() string

+ func (x *HelloRequest) ProtoReflect() protoreflect.Message

+ func (x *HelloRequest) Reset()

+ func (x *HelloRequest) String() string

+ type HelloResponse struct

+ ClientIp []byte

+ Redirect *RedirectMessage

+ func (*HelloResponse) Descriptor() ([]byte, []int)

+ func (*HelloResponse) ProtoMessage()

+ func (m *HelloResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *HelloResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *HelloResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *HelloResponse) SizeVT() (n int)

+ func (m *HelloResponse) UnmarshalVT(dAtA []byte) error

+ func (x *HelloResponse) GetClientIp() []byte

+ func (x *HelloResponse) GetRedirect() *RedirectMessage

+ func (x *HelloResponse) ProtoReflect() protoreflect.Message

+ func (x *HelloResponse) Reset()

+ func (x *HelloResponse) String() string

+ type ListRequest struct

+ ClusterId string

+ func (*ListRequest) Descriptor() ([]byte, []int)

+ func (*ListRequest) ProtoMessage()

+ func (m *ListRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ListRequest) SizeVT() (n int)

+ func (m *ListRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ListRequest) GetClusterId() string

+ func (x *ListRequest) ProtoReflect() protoreflect.Message

+ func (x *ListRequest) Reset()

+ func (x *ListRequest) String() string

+ type ListResponse struct

+ Affiliates []*Affiliate

+ func (*ListResponse) Descriptor() ([]byte, []int)

+ func (*ListResponse) ProtoMessage()

+ func (m *ListResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ListResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ListResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *ListResponse) SizeVT() (n int)

+ func (m *ListResponse) UnmarshalVT(dAtA []byte) error

+ func (x *ListResponse) GetAffiliates() []*Affiliate

+ func (x *ListResponse) ProtoReflect() protoreflect.Message

+ func (x *ListResponse) Reset()

+ func (x *ListResponse) String() string

+ type RedirectMessage struct

+ Endpoint string

+ func (*RedirectMessage) Descriptor() ([]byte, []int)

+ func (*RedirectMessage) ProtoMessage()

+ func (m *RedirectMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RedirectMessage) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RedirectMessage) MarshalVT() (dAtA []byte, err error)

+ func (m *RedirectMessage) SizeVT() (n int)

+ func (m *RedirectMessage) UnmarshalVT(dAtA []byte) error

+ func (x *RedirectMessage) GetEndpoint() string

+ func (x *RedirectMessage) ProtoReflect() protoreflect.Message

+ func (x *RedirectMessage) Reset()

+ func (x *RedirectMessage) String() string

+ type UnimplementedClusterServer struct

+ func (UnimplementedClusterServer) AffiliateDelete(context.Context, *AffiliateDeleteRequest) (*AffiliateDeleteResponse, error)

+ func (UnimplementedClusterServer) AffiliateUpdate(context.Context, *AffiliateUpdateRequest) (*AffiliateUpdateResponse, error)

+ func (UnimplementedClusterServer) Hello(context.Context, *HelloRequest) (*HelloResponse, error)

+ func (UnimplementedClusterServer) List(context.Context, *ListRequest) (*ListResponse, error)

+ func (UnimplementedClusterServer) Watch(*WatchRequest, Cluster_WatchServer) error

+ type UnsafeClusterServer interface

+ type WatchRequest struct

+ ClusterId string

+ func (*WatchRequest) Descriptor() ([]byte, []int)

+ func (*WatchRequest) ProtoMessage()

+ func (m *WatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *WatchRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *WatchRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *WatchRequest) SizeVT() (n int)

+ func (m *WatchRequest) UnmarshalVT(dAtA []byte) error

+ func (x *WatchRequest) GetClusterId() string

+ func (x *WatchRequest) ProtoReflect() protoreflect.Message

+ func (x *WatchRequest) Reset()

+ func (x *WatchRequest) String() string

+ type WatchResponse struct

+ Affiliates []*Affiliate

+ Deleted bool

+ func (*WatchResponse) Descriptor() ([]byte, []int)

+ func (*WatchResponse) ProtoMessage()

+ func (m *WatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *WatchResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *WatchResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *WatchResponse) SizeVT() (n int)

+ func (m *WatchResponse) UnmarshalVT(dAtA []byte) error

+ func (x *WatchResponse) GetAffiliates() []*Affiliate

+ func (x *WatchResponse) GetDeleted() bool

+ func (x *WatchResponse) ProtoReflect() protoreflect.Message

+ func (x *WatchResponse) Reset()

+ func (x *WatchResponse) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL