replicationtypes

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2023 License: Apache-2.0, MIT Imports: 19 Imported by: 2

Documentation

Overview

Package replicationtypes is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ServiceReplicationRegisteredPrefix = "user_registration"
	ServiceReplicationKeyGroupPrefix   = "group"
)

Variables

View Source 
var (
	ErrInvalidLengthBertyreplication        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBertyreplication          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBertyreplication = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ReplicationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "weshnet.replication.v1.ReplicationService",
	HandlerType: (*ReplicationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReplicateGroup",
			Handler:    _ReplicationService_ReplicateGroup_Handler,
		},
		{
			MethodName: "ReplicateGlobalStats",
			Handler:    _ReplicationService_ReplicateGlobalStats_Handler,
		},
		{
			MethodName: "ReplicateGroupStats",
			Handler:    _ReplicationService_ReplicateGroupStats_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "replicationtypes/bertyreplication.proto",
}

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

Functions

func RegisterReplicationServiceHandler 

func RegisterReplicationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterReplicationServiceHandler registers the http handlers for service ReplicationService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterReplicationServiceHandlerClient 

func RegisterReplicationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ReplicationServiceClient) error

RegisterReplicationServiceHandlerClient registers the http handlers for service ReplicationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ReplicationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ReplicationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ReplicationServiceClient" to call the correct interceptors.

func RegisterReplicationServiceHandlerFromEndpoint 

func RegisterReplicationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterReplicationServiceHandlerFromEndpoint is same as RegisterReplicationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterReplicationServiceHandlerServer 

func RegisterReplicationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ReplicationServiceServer) error

RegisterReplicationServiceHandlerServer registers the http handlers for service ReplicationService to "mux". UnaryRPC :call ReplicationServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterReplicationServiceHandlerFromEndpoint instead.

func RegisterReplicationServiceServer 

func RegisterReplicationServiceServer(s grpc.ServiceRegistrar, srv ReplicationServiceServer)

Types

type ReplicateGlobalStats 

type ReplicateGlobalStats struct {
}

func (*ReplicateGlobalStats) Descriptor 

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

func (*ReplicateGlobalStats) Marshal 

func (m *ReplicateGlobalStats) Marshal() (dAtA []byte, err error)

func (*ReplicateGlobalStats) MarshalTo 

func (m *ReplicateGlobalStats) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateGlobalStats) MarshalToSizedBuffer 

func (m *ReplicateGlobalStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateGlobalStats) ProtoMessage 

func (*ReplicateGlobalStats) ProtoMessage()

func (*ReplicateGlobalStats) Reset 

func (m *ReplicateGlobalStats) Reset()

func (*ReplicateGlobalStats) Size 

func (m *ReplicateGlobalStats) Size() (n int)

func (*ReplicateGlobalStats) String 

func (m *ReplicateGlobalStats) String() string

func (*ReplicateGlobalStats) Unmarshal 

func (m *ReplicateGlobalStats) Unmarshal(dAtA []byte) error

func (*ReplicateGlobalStats) XXX_DiscardUnknown 

func (m *ReplicateGlobalStats) XXX_DiscardUnknown()

func (*ReplicateGlobalStats) XXX_Marshal 

func (m *ReplicateGlobalStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicateGlobalStats) XXX_Merge 

func (m *ReplicateGlobalStats) XXX_Merge(src proto.Message)

func (*ReplicateGlobalStats) XXX_Size 

func (m *ReplicateGlobalStats) XXX_Size() int

func (*ReplicateGlobalStats) XXX_Unmarshal 

func (m *ReplicateGlobalStats) XXX_Unmarshal(b []byte) error

type ReplicateGlobalStats_Reply 

type ReplicateGlobalStats_Reply struct {
	StartedAt            int64 `protobuf:"varint,1,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ReplicatedGroups     int64 `protobuf:"varint,2,opt,name=replicated_groups,json=replicatedGroups,proto3" json:"replicated_groups,omitempty"`
	TotalMetadataEntries int64 `protobuf:"varint,3,opt,name=total_metadata_entries,json=totalMetadataEntries,proto3" json:"total_metadata_entries,omitempty"`
	TotalMessageEntries  int64 `protobuf:"varint,4,opt,name=total_message_entries,json=totalMessageEntries,proto3" json:"total_message_entries,omitempty"`
}

func (*ReplicateGlobalStats_Reply) Descriptor 

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

func (*ReplicateGlobalStats_Reply) GetReplicatedGroups 

func (m *ReplicateGlobalStats_Reply) GetReplicatedGroups() int64

func (*ReplicateGlobalStats_Reply) GetStartedAt 

func (m *ReplicateGlobalStats_Reply) GetStartedAt() int64

func (*ReplicateGlobalStats_Reply) GetTotalMessageEntries 

func (m *ReplicateGlobalStats_Reply) GetTotalMessageEntries() int64

func (*ReplicateGlobalStats_Reply) GetTotalMetadataEntries 

func (m *ReplicateGlobalStats_Reply) GetTotalMetadataEntries() int64

func (*ReplicateGlobalStats_Reply) Marshal 

func (m *ReplicateGlobalStats_Reply) Marshal() (dAtA []byte, err error)

func (*ReplicateGlobalStats_Reply) MarshalTo 

func (m *ReplicateGlobalStats_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateGlobalStats_Reply) MarshalToSizedBuffer 

func (m *ReplicateGlobalStats_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateGlobalStats_Reply) ProtoMessage 

func (*ReplicateGlobalStats_Reply) ProtoMessage()

func (*ReplicateGlobalStats_Reply) Reset 

func (m *ReplicateGlobalStats_Reply) Reset()

func (*ReplicateGlobalStats_Reply) Size 

func (m *ReplicateGlobalStats_Reply) Size() (n int)

func (*ReplicateGlobalStats_Reply) String 

func (m *ReplicateGlobalStats_Reply) String() string

func (*ReplicateGlobalStats_Reply) Unmarshal 

func (m *ReplicateGlobalStats_Reply) Unmarshal(dAtA []byte) error

func (*ReplicateGlobalStats_Reply) XXX_DiscardUnknown 

func (m *ReplicateGlobalStats_Reply) XXX_DiscardUnknown()

func (*ReplicateGlobalStats_Reply) XXX_Marshal 

func (m *ReplicateGlobalStats_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicateGlobalStats_Reply) XXX_Merge 

func (m *ReplicateGlobalStats_Reply) XXX_Merge(src proto.Message)

func (*ReplicateGlobalStats_Reply) XXX_Size 

func (m *ReplicateGlobalStats_Reply) XXX_Size() int

func (*ReplicateGlobalStats_Reply) XXX_Unmarshal 

func (m *ReplicateGlobalStats_Reply) XXX_Unmarshal(b []byte) error

type ReplicateGlobalStats_Request 

type ReplicateGlobalStats_Request struct {
}

func (*ReplicateGlobalStats_Request) Descriptor 

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

func (*ReplicateGlobalStats_Request) Marshal 

func (m *ReplicateGlobalStats_Request) Marshal() (dAtA []byte, err error)

func (*ReplicateGlobalStats_Request) MarshalTo 

func (m *ReplicateGlobalStats_Request) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateGlobalStats_Request) MarshalToSizedBuffer 

func (m *ReplicateGlobalStats_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateGlobalStats_Request) ProtoMessage 

func (*ReplicateGlobalStats_Request) ProtoMessage()

func (*ReplicateGlobalStats_Request) Reset 

func (m *ReplicateGlobalStats_Request) Reset()

func (*ReplicateGlobalStats_Request) Size 

func (m *ReplicateGlobalStats_Request) Size() (n int)

func (*ReplicateGlobalStats_Request) String 

func (m *ReplicateGlobalStats_Request) String() string

func (*ReplicateGlobalStats_Request) Unmarshal 

func (m *ReplicateGlobalStats_Request) Unmarshal(dAtA []byte) error

func (*ReplicateGlobalStats_Request) XXX_DiscardUnknown 

func (m *ReplicateGlobalStats_Request) XXX_DiscardUnknown()

func (*ReplicateGlobalStats_Request) XXX_Marshal 

func (m *ReplicateGlobalStats_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicateGlobalStats_Request) XXX_Merge 

func (m *ReplicateGlobalStats_Request) XXX_Merge(src proto.Message)

func (*ReplicateGlobalStats_Request) XXX_Size 

func (m *ReplicateGlobalStats_Request) XXX_Size() int

func (*ReplicateGlobalStats_Request) XXX_Unmarshal 

func (m *ReplicateGlobalStats_Request) XXX_Unmarshal(b []byte) error

type ReplicateGroupStats 

type ReplicateGroupStats struct {
}

func (*ReplicateGroupStats) Descriptor 

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

func (*ReplicateGroupStats) Marshal 

func (m *ReplicateGroupStats) Marshal() (dAtA []byte, err error)

func (*ReplicateGroupStats) MarshalTo 

func (m *ReplicateGroupStats) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateGroupStats) MarshalToSizedBuffer 

func (m *ReplicateGroupStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateGroupStats) ProtoMessage 

func (*ReplicateGroupStats) ProtoMessage()

func (*ReplicateGroupStats) Reset 

func (m *ReplicateGroupStats) Reset()

func (*ReplicateGroupStats) Size 

func (m *ReplicateGroupStats) Size() (n int)

func (*ReplicateGroupStats) String 

func (m *ReplicateGroupStats) String() string

func (*ReplicateGroupStats) Unmarshal 

func (m *ReplicateGroupStats) Unmarshal(dAtA []byte) error

func (*ReplicateGroupStats) XXX_DiscardUnknown 

func (m *ReplicateGroupStats) XXX_DiscardUnknown()

func (*ReplicateGroupStats) XXX_Marshal 

func (m *ReplicateGroupStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicateGroupStats) XXX_Merge 

func (m *ReplicateGroupStats) XXX_Merge(src proto.Message)

func (*ReplicateGroupStats) XXX_Size 

func (m *ReplicateGroupStats) XXX_Size() int

func (*ReplicateGroupStats) XXX_Unmarshal 

func (m *ReplicateGroupStats) XXX_Unmarshal(b []byte) error

type ReplicateGroupStats_Reply 

type ReplicateGroupStats_Reply struct {
	Group *ReplicatedGroup `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
}

func (*ReplicateGroupStats_Reply) Descriptor 

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

func (*ReplicateGroupStats_Reply) GetGroup 

func (m *ReplicateGroupStats_Reply) GetGroup() *ReplicatedGroup

func (*ReplicateGroupStats_Reply) Marshal 

func (m *ReplicateGroupStats_Reply) Marshal() (dAtA []byte, err error)

func (*ReplicateGroupStats_Reply) MarshalTo 

func (m *ReplicateGroupStats_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateGroupStats_Reply) MarshalToSizedBuffer 

func (m *ReplicateGroupStats_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateGroupStats_Reply) ProtoMessage 

func (*ReplicateGroupStats_Reply) ProtoMessage()

func (*ReplicateGroupStats_Reply) Reset 

func (m *ReplicateGroupStats_Reply) Reset()

func (*ReplicateGroupStats_Reply) Size 

func (m *ReplicateGroupStats_Reply) Size() (n int)

func (*ReplicateGroupStats_Reply) String 

func (m *ReplicateGroupStats_Reply) String() string

func (*ReplicateGroupStats_Reply) Unmarshal 

func (m *ReplicateGroupStats_Reply) Unmarshal(dAtA []byte) error

func (*ReplicateGroupStats_Reply) XXX_DiscardUnknown 

func (m *ReplicateGroupStats_Reply) XXX_DiscardUnknown()

func (*ReplicateGroupStats_Reply) XXX_Marshal 

func (m *ReplicateGroupStats_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicateGroupStats_Reply) XXX_Merge 

func (m *ReplicateGroupStats_Reply) XXX_Merge(src proto.Message)

func (*ReplicateGroupStats_Reply) XXX_Size 

func (m *ReplicateGroupStats_Reply) XXX_Size() int

func (*ReplicateGroupStats_Reply) XXX_Unmarshal 

func (m *ReplicateGroupStats_Reply) XXX_Unmarshal(b []byte) error

type ReplicateGroupStats_Request 

type ReplicateGroupStats_Request struct {
	GroupPublicKey string `protobuf:"bytes,1,opt,name=group_public_key,json=groupPublicKey,proto3" json:"group_public_key,omitempty"`
}

func (*ReplicateGroupStats_Request) Descriptor 

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

func (*ReplicateGroupStats_Request) GetGroupPublicKey 

func (m *ReplicateGroupStats_Request) GetGroupPublicKey() string

func (*ReplicateGroupStats_Request) Marshal 

func (m *ReplicateGroupStats_Request) Marshal() (dAtA []byte, err error)

func (*ReplicateGroupStats_Request) MarshalTo 

func (m *ReplicateGroupStats_Request) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateGroupStats_Request) MarshalToSizedBuffer 

func (m *ReplicateGroupStats_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateGroupStats_Request) ProtoMessage 

func (*ReplicateGroupStats_Request) ProtoMessage()

func (*ReplicateGroupStats_Request) Reset 

func (m *ReplicateGroupStats_Request) Reset()

func (*ReplicateGroupStats_Request) Size 

func (m *ReplicateGroupStats_Request) Size() (n int)

func (*ReplicateGroupStats_Request) String 

func (m *ReplicateGroupStats_Request) String() string

func (*ReplicateGroupStats_Request) Unmarshal 

func (m *ReplicateGroupStats_Request) Unmarshal(dAtA []byte) error

func (*ReplicateGroupStats_Request) XXX_DiscardUnknown 

func (m *ReplicateGroupStats_Request) XXX_DiscardUnknown()

func (*ReplicateGroupStats_Request) XXX_Marshal 

func (m *ReplicateGroupStats_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicateGroupStats_Request) XXX_Merge 

func (m *ReplicateGroupStats_Request) XXX_Merge(src proto.Message)

func (*ReplicateGroupStats_Request) XXX_Size 

func (m *ReplicateGroupStats_Request) XXX_Size() int

func (*ReplicateGroupStats_Request) XXX_Unmarshal 

func (m *ReplicateGroupStats_Request) XXX_Unmarshal(b []byte) error

type ReplicatedGroup 

type ReplicatedGroup struct {
	PublicKey            string `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty" gorm:"primaryKey"`
	SignPub              string `protobuf:"bytes,2,opt,name=sign_pub,json=signPub,proto3" json:"sign_pub,omitempty"`
	LinkKey              string `protobuf:"bytes,3,opt,name=link_key,json=linkKey,proto3" json:"link_key,omitempty"`
	CreatedAt            int64  `protobuf:"varint,100,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            int64  `protobuf:"varint,101,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	MetadataEntriesCount int64  `` /* 126-byte string literal not displayed */
	MetadataLatestHead   string `protobuf:"bytes,103,opt,name=metadata_latest_head,json=metadataLatestHead,proto3" json:"metadata_latest_head,omitempty"`
	MessageEntriesCount  int64  `protobuf:"varint,104,opt,name=message_entries_count,json=messageEntriesCount,proto3" json:"message_entries_count,omitempty"`
	MessageLatestHead    string `protobuf:"bytes,105,opt,name=message_latest_head,json=messageLatestHead,proto3" json:"message_latest_head,omitempty"`
}

func (*ReplicatedGroup) Descriptor 

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

func (*ReplicatedGroup) GetCreatedAt 

func (m *ReplicatedGroup) GetCreatedAt() int64

func (*ReplicatedGroup) GetLinkKey 

func (m *ReplicatedGroup) GetLinkKey() string

func (*ReplicatedGroup) GetMessageEntriesCount 

func (m *ReplicatedGroup) GetMessageEntriesCount() int64

func (*ReplicatedGroup) GetMessageLatestHead 

func (m *ReplicatedGroup) GetMessageLatestHead() string

func (*ReplicatedGroup) GetMetadataEntriesCount 

func (m *ReplicatedGroup) GetMetadataEntriesCount() int64

func (*ReplicatedGroup) GetMetadataLatestHead 

func (m *ReplicatedGroup) GetMetadataLatestHead() string

func (*ReplicatedGroup) GetPublicKey 

func (m *ReplicatedGroup) GetPublicKey() string

func (*ReplicatedGroup) GetSignPub 

func (m *ReplicatedGroup) GetSignPub() string

func (*ReplicatedGroup) GetUpdatedAt 

func (m *ReplicatedGroup) GetUpdatedAt() int64

func (*ReplicatedGroup) Marshal 

func (m *ReplicatedGroup) Marshal() (dAtA []byte, err error)

func (*ReplicatedGroup) MarshalTo 

func (m *ReplicatedGroup) MarshalTo(dAtA []byte) (int, error)

func (*ReplicatedGroup) MarshalToSizedBuffer 

func (m *ReplicatedGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicatedGroup) ProtoMessage 

func (*ReplicatedGroup) ProtoMessage()

func (*ReplicatedGroup) Reset 

func (m *ReplicatedGroup) Reset()

func (*ReplicatedGroup) Size 

func (m *ReplicatedGroup) Size() (n int)

func (*ReplicatedGroup) String 

func (m *ReplicatedGroup) String() string

func (*ReplicatedGroup) ToGroup 

func (m *ReplicatedGroup) ToGroup() (*protocoltypes.Group, error)

func (*ReplicatedGroup) Unmarshal 

func (m *ReplicatedGroup) Unmarshal(dAtA []byte) error

func (*ReplicatedGroup) XXX_DiscardUnknown 

func (m *ReplicatedGroup) XXX_DiscardUnknown()

func (*ReplicatedGroup) XXX_Marshal 

func (m *ReplicatedGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicatedGroup) XXX_Merge 

func (m *ReplicatedGroup) XXX_Merge(src proto.Message)

func (*ReplicatedGroup) XXX_Size 

func (m *ReplicatedGroup) XXX_Size() int

func (*ReplicatedGroup) XXX_Unmarshal 

func (m *ReplicatedGroup) XXX_Unmarshal(b []byte) error

type ReplicatedGroupToken 

type ReplicatedGroupToken struct {
	ReplicatedGroupPublicKey string           `` /* 181-byte string literal not displayed */
	ReplicatedGroup          *ReplicatedGroup `protobuf:"bytes,2,opt,name=replicated_group,json=replicatedGroup,proto3" json:"replicated_group,omitempty"`
	TokenIssuer              string           `` /* 132-byte string literal not displayed */
	TokenID                  string           `protobuf:"bytes,4,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty" gorm:"primaryKey;autoIncrement:false"`
	CreatedAt                int64            `protobuf:"varint,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

func (*ReplicatedGroupToken) Descriptor 

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

func (*ReplicatedGroupToken) GetCreatedAt 

func (m *ReplicatedGroupToken) GetCreatedAt() int64

func (*ReplicatedGroupToken) GetReplicatedGroup 

func (m *ReplicatedGroupToken) GetReplicatedGroup() *ReplicatedGroup

func (*ReplicatedGroupToken) GetReplicatedGroupPublicKey 

func (m *ReplicatedGroupToken) GetReplicatedGroupPublicKey() string

func (*ReplicatedGroupToken) GetTokenID 

func (m *ReplicatedGroupToken) GetTokenID() string

func (*ReplicatedGroupToken) GetTokenIssuer 

func (m *ReplicatedGroupToken) GetTokenIssuer() string

func (*ReplicatedGroupToken) Marshal 

func (m *ReplicatedGroupToken) Marshal() (dAtA []byte, err error)

func (*ReplicatedGroupToken) MarshalTo 

func (m *ReplicatedGroupToken) MarshalTo(dAtA []byte) (int, error)

func (*ReplicatedGroupToken) MarshalToSizedBuffer 

func (m *ReplicatedGroupToken) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicatedGroupToken) ProtoMessage 

func (*ReplicatedGroupToken) ProtoMessage()

func (*ReplicatedGroupToken) Reset 

func (m *ReplicatedGroupToken) Reset()

func (*ReplicatedGroupToken) Size 

func (m *ReplicatedGroupToken) Size() (n int)

func (*ReplicatedGroupToken) String 

func (m *ReplicatedGroupToken) String() string

func (*ReplicatedGroupToken) Unmarshal 

func (m *ReplicatedGroupToken) Unmarshal(dAtA []byte) error

func (*ReplicatedGroupToken) XXX_DiscardUnknown 

func (m *ReplicatedGroupToken) XXX_DiscardUnknown()

func (*ReplicatedGroupToken) XXX_Marshal 

func (m *ReplicatedGroupToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicatedGroupToken) XXX_Merge 

func (m *ReplicatedGroupToken) XXX_Merge(src proto.Message)

func (*ReplicatedGroupToken) XXX_Size 

func (m *ReplicatedGroupToken) XXX_Size() int

func (*ReplicatedGroupToken) XXX_Unmarshal 

func (m *ReplicatedGroupToken) XXX_Unmarshal(b []byte) error

type ReplicationServiceClient 

type ReplicationServiceClient interface {
	// ReplicateGroup
	ReplicateGroup(ctx context.Context, in *ReplicationServiceReplicateGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceReplicateGroup_Reply, error)
	ReplicateGlobalStats(ctx context.Context, in *ReplicateGlobalStats_Request, opts ...grpc.CallOption) (*ReplicateGlobalStats_Reply, error)
	ReplicateGroupStats(ctx context.Context, in *ReplicateGroupStats_Request, opts ...grpc.CallOption) (*ReplicateGroupStats_Reply, error)
}

ReplicationServiceClient is the client API for ReplicationService 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 NewReplicationServiceClient 

func NewReplicationServiceClient(cc grpc.ClientConnInterface) ReplicationServiceClient

type ReplicationServiceReplicateGroup 

type ReplicationServiceReplicateGroup struct {
}

func (*ReplicationServiceReplicateGroup) Descriptor 

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

func (*ReplicationServiceReplicateGroup) Marshal 

func (m *ReplicationServiceReplicateGroup) Marshal() (dAtA []byte, err error)

func (*ReplicationServiceReplicateGroup) MarshalTo 

func (m *ReplicationServiceReplicateGroup) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationServiceReplicateGroup) MarshalToSizedBuffer 

func (m *ReplicationServiceReplicateGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationServiceReplicateGroup) ProtoMessage 

func (*ReplicationServiceReplicateGroup) ProtoMessage()

func (*ReplicationServiceReplicateGroup) Reset 

func (m *ReplicationServiceReplicateGroup) Reset()

func (*ReplicationServiceReplicateGroup) Size 

func (m *ReplicationServiceReplicateGroup) Size() (n int)

func (*ReplicationServiceReplicateGroup) String 

func (m *ReplicationServiceReplicateGroup) String() string

func (*ReplicationServiceReplicateGroup) Unmarshal 

func (m *ReplicationServiceReplicateGroup) Unmarshal(dAtA []byte) error

func (*ReplicationServiceReplicateGroup) XXX_DiscardUnknown 

func (m *ReplicationServiceReplicateGroup) XXX_DiscardUnknown()

func (*ReplicationServiceReplicateGroup) XXX_Marshal 

func (m *ReplicationServiceReplicateGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationServiceReplicateGroup) XXX_Merge 

func (m *ReplicationServiceReplicateGroup) XXX_Merge(src proto.Message)

func (*ReplicationServiceReplicateGroup) XXX_Size 

func (m *ReplicationServiceReplicateGroup) XXX_Size() int

func (*ReplicationServiceReplicateGroup) XXX_Unmarshal 

func (m *ReplicationServiceReplicateGroup) XXX_Unmarshal(b []byte) error

type ReplicationServiceReplicateGroup_Reply 

type ReplicationServiceReplicateGroup_Reply struct {
	OK bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
}

func (*ReplicationServiceReplicateGroup_Reply) Descriptor 

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

func (*ReplicationServiceReplicateGroup_Reply) GetOK 

func (m *ReplicationServiceReplicateGroup_Reply) GetOK() bool

func (*ReplicationServiceReplicateGroup_Reply) Marshal 

func (m *ReplicationServiceReplicateGroup_Reply) Marshal() (dAtA []byte, err error)

func (*ReplicationServiceReplicateGroup_Reply) MarshalTo 

func (m *ReplicationServiceReplicateGroup_Reply) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationServiceReplicateGroup_Reply) MarshalToSizedBuffer 

func (m *ReplicationServiceReplicateGroup_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationServiceReplicateGroup_Reply) ProtoMessage 

func (*ReplicationServiceReplicateGroup_Reply) ProtoMessage()

func (*ReplicationServiceReplicateGroup_Reply) Reset 

func (m *ReplicationServiceReplicateGroup_Reply) Reset()

func (*ReplicationServiceReplicateGroup_Reply) Size 

func (m *ReplicationServiceReplicateGroup_Reply) Size() (n int)

func (*ReplicationServiceReplicateGroup_Reply) String 

func (m *ReplicationServiceReplicateGroup_Reply) String() string

func (*ReplicationServiceReplicateGroup_Reply) Unmarshal 

func (m *ReplicationServiceReplicateGroup_Reply) Unmarshal(dAtA []byte) error

func (*ReplicationServiceReplicateGroup_Reply) XXX_DiscardUnknown 

func (m *ReplicationServiceReplicateGroup_Reply) XXX_DiscardUnknown()

func (*ReplicationServiceReplicateGroup_Reply) XXX_Marshal 

func (m *ReplicationServiceReplicateGroup_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationServiceReplicateGroup_Reply) XXX_Merge 

func (m *ReplicationServiceReplicateGroup_Reply) XXX_Merge(src proto.Message)

func (*ReplicationServiceReplicateGroup_Reply) XXX_Size 

func (m *ReplicationServiceReplicateGroup_Reply) XXX_Size() int

func (*ReplicationServiceReplicateGroup_Reply) XXX_Unmarshal 

func (m *ReplicationServiceReplicateGroup_Reply) XXX_Unmarshal(b []byte) error

type ReplicationServiceReplicateGroup_Request 

type ReplicationServiceReplicateGroup_Request struct {
	Group *protocoltypes.Group `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
}

func (*ReplicationServiceReplicateGroup_Request) Descriptor 

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

func (*ReplicationServiceReplicateGroup_Request) GetGroup 

func (m *ReplicationServiceReplicateGroup_Request) GetGroup() *protocoltypes.Group

func (*ReplicationServiceReplicateGroup_Request) Marshal 

func (m *ReplicationServiceReplicateGroup_Request) Marshal() (dAtA []byte, err error)

func (*ReplicationServiceReplicateGroup_Request) MarshalTo 

func (m *ReplicationServiceReplicateGroup_Request) MarshalTo(dAtA []byte) (int, error)

func (*ReplicationServiceReplicateGroup_Request) MarshalToSizedBuffer 

func (m *ReplicationServiceReplicateGroup_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicationServiceReplicateGroup_Request) ProtoMessage 

func (*ReplicationServiceReplicateGroup_Request) ProtoMessage()

func (*ReplicationServiceReplicateGroup_Request) Reset 

func (m *ReplicationServiceReplicateGroup_Request) Reset()

func (*ReplicationServiceReplicateGroup_Request) Size 

func (m *ReplicationServiceReplicateGroup_Request) Size() (n int)

func (*ReplicationServiceReplicateGroup_Request) String 

func (m *ReplicationServiceReplicateGroup_Request) String() string

func (*ReplicationServiceReplicateGroup_Request) Unmarshal 

func (m *ReplicationServiceReplicateGroup_Request) Unmarshal(dAtA []byte) error

func (*ReplicationServiceReplicateGroup_Request) XXX_DiscardUnknown 

func (m *ReplicationServiceReplicateGroup_Request) XXX_DiscardUnknown()

func (*ReplicationServiceReplicateGroup_Request) XXX_Marshal 

func (m *ReplicationServiceReplicateGroup_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationServiceReplicateGroup_Request) XXX_Merge 

func (m *ReplicationServiceReplicateGroup_Request) XXX_Merge(src proto.Message)

func (*ReplicationServiceReplicateGroup_Request) XXX_Size 

func (m *ReplicationServiceReplicateGroup_Request) XXX_Size() int

func (*ReplicationServiceReplicateGroup_Request) XXX_Unmarshal 

func (m *ReplicationServiceReplicateGroup_Request) XXX_Unmarshal(b []byte) error

type ReplicationServiceServer 

type ReplicationServiceServer interface {
	// ReplicateGroup
	ReplicateGroup(context.Context, *ReplicationServiceReplicateGroup_Request) (*ReplicationServiceReplicateGroup_Reply, error)
	ReplicateGlobalStats(context.Context, *ReplicateGlobalStats_Request) (*ReplicateGlobalStats_Reply, error)
	ReplicateGroupStats(context.Context, *ReplicateGroupStats_Request) (*ReplicateGroupStats_Reply, error)
	// contains filtered or unexported methods
}

ReplicationServiceServer is the server API for ReplicationService service. All implementations must embed UnimplementedReplicationServiceServer for forward compatibility

type UnimplementedReplicationServiceServer 

type UnimplementedReplicationServiceServer struct {
}

UnimplementedReplicationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReplicationServiceServer) ReplicateGlobalStats 

func (UnimplementedReplicationServiceServer) ReplicateGlobalStats(context.Context, *ReplicateGlobalStats_Request) (*ReplicateGlobalStats_Reply, error)

func (UnimplementedReplicationServiceServer) ReplicateGroup 

func (UnimplementedReplicationServiceServer) ReplicateGroup(context.Context, *ReplicationServiceReplicateGroup_Request) (*ReplicationServiceReplicateGroup_Reply, error)

func (UnimplementedReplicationServiceServer) ReplicateGroupStats 

func (UnimplementedReplicationServiceServer) ReplicateGroupStats(context.Context, *ReplicateGroupStats_Request) (*ReplicateGroupStats_Reply, error)

type UnsafeReplicationServiceServer 

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

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