gravity_api_synchronizer

package
v0.2.13 Latest Latest
Warning

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

 Go to latest Published: May 19, 2021 License: MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSynchronizerServer 

func RegisterSynchronizerServer(s *grpc.Server, srv SynchronizerServer)

Types

type AssignPipelineReply 

type AssignPipelineReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssignPipelineReply) Descriptor 

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

func (*AssignPipelineReply) GetReason 

func (m *AssignPipelineReply) GetReason() string

func (*AssignPipelineReply) GetSuccess 

func (m *AssignPipelineReply) GetSuccess() bool

func (*AssignPipelineReply) ProtoMessage 

func (*AssignPipelineReply) ProtoMessage()

func (*AssignPipelineReply) Reset 

func (m *AssignPipelineReply) Reset()

func (*AssignPipelineReply) String 

func (m *AssignPipelineReply) String() string

func (*AssignPipelineReply) XXX_DiscardUnknown 

func (m *AssignPipelineReply) XXX_DiscardUnknown()

func (*AssignPipelineReply) XXX_Marshal 

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

func (*AssignPipelineReply) XXX_Merge 

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

func (*AssignPipelineReply) XXX_Size 

func (m *AssignPipelineReply) XXX_Size() int

func (*AssignPipelineReply) XXX_Unmarshal 

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

type AssignPipelineRequest 

type AssignPipelineRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	PipelineID           uint64   `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssignPipelineRequest) Descriptor 

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

func (*AssignPipelineRequest) GetClientID 

func (m *AssignPipelineRequest) GetClientID() string

func (*AssignPipelineRequest) GetPipelineID 

func (m *AssignPipelineRequest) GetPipelineID() uint64

func (*AssignPipelineRequest) ProtoMessage 

func (*AssignPipelineRequest) ProtoMessage()

func (*AssignPipelineRequest) Reset 

func (m *AssignPipelineRequest) Reset()

func (*AssignPipelineRequest) String 

func (m *AssignPipelineRequest) String() string

func (*AssignPipelineRequest) XXX_DiscardUnknown 

func (m *AssignPipelineRequest) XXX_DiscardUnknown()

func (*AssignPipelineRequest) XXX_Marshal 

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

func (*AssignPipelineRequest) XXX_Merge 

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

func (*AssignPipelineRequest) XXX_Size 

func (m *AssignPipelineRequest) XXX_Size() int

func (*AssignPipelineRequest) XXX_Unmarshal 

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

type GetPipelineStateReply 

type GetPipelineStateReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	LastSeq              uint64   `protobuf:"varint,3,opt,name=lastSeq,proto3" json:"lastSeq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelineStateReply) Descriptor 

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

func (*GetPipelineStateReply) GetLastSeq 

func (m *GetPipelineStateReply) GetLastSeq() uint64

func (*GetPipelineStateReply) GetReason 

func (m *GetPipelineStateReply) GetReason() string

func (*GetPipelineStateReply) GetSuccess 

func (m *GetPipelineStateReply) GetSuccess() bool

func (*GetPipelineStateReply) ProtoMessage 

func (*GetPipelineStateReply) ProtoMessage()

func (*GetPipelineStateReply) Reset 

func (m *GetPipelineStateReply) Reset()

func (*GetPipelineStateReply) String 

func (m *GetPipelineStateReply) String() string

func (*GetPipelineStateReply) XXX_DiscardUnknown 

func (m *GetPipelineStateReply) XXX_DiscardUnknown()

func (*GetPipelineStateReply) XXX_Marshal 

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

func (*GetPipelineStateReply) XXX_Merge 

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

func (*GetPipelineStateReply) XXX_Size 

func (m *GetPipelineStateReply) XXX_Size() int

func (*GetPipelineStateReply) XXX_Unmarshal 

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

type GetPipelineStateRequest 

type GetPipelineStateRequest struct {
	PipelineID           string   `protobuf:"bytes,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelineStateRequest) Descriptor 

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

func (*GetPipelineStateRequest) GetPipelineID 

func (m *GetPipelineStateRequest) GetPipelineID() string

func (*GetPipelineStateRequest) ProtoMessage 

func (*GetPipelineStateRequest) ProtoMessage()

func (*GetPipelineStateRequest) Reset 

func (m *GetPipelineStateRequest) Reset()

func (*GetPipelineStateRequest) String 

func (m *GetPipelineStateRequest) String() string

func (*GetPipelineStateRequest) XXX_DiscardUnknown 

func (m *GetPipelineStateRequest) XXX_DiscardUnknown()

func (*GetPipelineStateRequest) XXX_Marshal 

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

func (*GetPipelineStateRequest) XXX_Merge 

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

func (*GetPipelineStateRequest) XXX_Size 

func (m *GetPipelineStateRequest) XXX_Size() int

func (*GetPipelineStateRequest) XXX_Unmarshal 

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

type PipelineFetchReply 

type PipelineFetchReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Count                uint64   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	LastSeq              uint64   `protobuf:"varint,4,opt,name=lastSeq,proto3" json:"lastSeq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PipelineFetchReply) Descriptor 

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

func (*PipelineFetchReply) GetCount 

func (m *PipelineFetchReply) GetCount() uint64

func (*PipelineFetchReply) GetLastSeq 

func (m *PipelineFetchReply) GetLastSeq() uint64

func (*PipelineFetchReply) GetReason 

func (m *PipelineFetchReply) GetReason() string

func (*PipelineFetchReply) GetSuccess 

func (m *PipelineFetchReply) GetSuccess() bool

func (*PipelineFetchReply) ProtoMessage 

func (*PipelineFetchReply) ProtoMessage()

func (*PipelineFetchReply) Reset 

func (m *PipelineFetchReply) Reset()

func (*PipelineFetchReply) String 

func (m *PipelineFetchReply) String() string

func (*PipelineFetchReply) XXX_DiscardUnknown 

func (m *PipelineFetchReply) XXX_DiscardUnknown()

func (*PipelineFetchReply) XXX_Marshal 

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

func (*PipelineFetchReply) XXX_Merge 

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

func (*PipelineFetchReply) XXX_Size 

func (m *PipelineFetchReply) XXX_Size() int

func (*PipelineFetchReply) XXX_Unmarshal 

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

type PipelineFetchRequest 

type PipelineFetchRequest struct {
	SubscriberID         string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	PipelineID           uint64   `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	StartAt              uint64   `protobuf:"varint,3,opt,name=startAt,proto3" json:"startAt,omitempty"`
	Offset               uint64   `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Count                int64    `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PipelineFetchRequest) Descriptor 

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

func (*PipelineFetchRequest) GetCount 

func (m *PipelineFetchRequest) GetCount() int64

func (*PipelineFetchRequest) GetOffset 

func (m *PipelineFetchRequest) GetOffset() uint64

func (*PipelineFetchRequest) GetPipelineID 

func (m *PipelineFetchRequest) GetPipelineID() uint64

func (*PipelineFetchRequest) GetStartAt 

func (m *PipelineFetchRequest) GetStartAt() uint64

func (*PipelineFetchRequest) GetSubscriberID 

func (m *PipelineFetchRequest) GetSubscriberID() string

func (*PipelineFetchRequest) ProtoMessage 

func (*PipelineFetchRequest) ProtoMessage()

func (*PipelineFetchRequest) Reset 

func (m *PipelineFetchRequest) Reset()

func (*PipelineFetchRequest) String 

func (m *PipelineFetchRequest) String() string

func (*PipelineFetchRequest) XXX_DiscardUnknown 

func (m *PipelineFetchRequest) XXX_DiscardUnknown()

func (*PipelineFetchRequest) XXX_Marshal 

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

func (*PipelineFetchRequest) XXX_Merge 

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

func (*PipelineFetchRequest) XXX_Size 

func (m *PipelineFetchRequest) XXX_Size() int

func (*PipelineFetchRequest) XXX_Unmarshal 

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

type RegisterSubscriberReply 

type RegisterSubscriberReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterSubscriberReply) Descriptor 

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

func (*RegisterSubscriberReply) GetReason 

func (m *RegisterSubscriberReply) GetReason() string

func (*RegisterSubscriberReply) GetSuccess 

func (m *RegisterSubscriberReply) GetSuccess() bool

func (*RegisterSubscriberReply) ProtoMessage 

func (*RegisterSubscriberReply) ProtoMessage()

func (*RegisterSubscriberReply) Reset 

func (m *RegisterSubscriberReply) Reset()

func (*RegisterSubscriberReply) String 

func (m *RegisterSubscriberReply) String() string

func (*RegisterSubscriberReply) XXX_DiscardUnknown 

func (m *RegisterSubscriberReply) XXX_DiscardUnknown()

func (*RegisterSubscriberReply) XXX_Marshal 

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

func (*RegisterSubscriberReply) XXX_Merge 

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

func (*RegisterSubscriberReply) XXX_Size 

func (m *RegisterSubscriberReply) XXX_Size() int

func (*RegisterSubscriberReply) XXX_Unmarshal 

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

type RegisterSubscriberRequest 

type RegisterSubscriberRequest struct {
	SubscriberID         string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterSubscriberRequest) Descriptor 

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

func (*RegisterSubscriberRequest) GetName 

func (m *RegisterSubscriberRequest) GetName() string

func (*RegisterSubscriberRequest) GetSubscriberID 

func (m *RegisterSubscriberRequest) GetSubscriberID() string

func (*RegisterSubscriberRequest) ProtoMessage 

func (*RegisterSubscriberRequest) ProtoMessage()

func (*RegisterSubscriberRequest) Reset 

func (m *RegisterSubscriberRequest) Reset()

func (*RegisterSubscriberRequest) String 

func (m *RegisterSubscriberRequest) String() string

func (*RegisterSubscriberRequest) XXX_DiscardUnknown 

func (m *RegisterSubscriberRequest) XXX_DiscardUnknown()

func (*RegisterSubscriberRequest) XXX_Marshal 

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

func (*RegisterSubscriberRequest) XXX_Merge 

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

func (*RegisterSubscriberRequest) XXX_Size 

func (m *RegisterSubscriberRequest) XXX_Size() int

func (*RegisterSubscriberRequest) XXX_Unmarshal 

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

type RevokePipelineReply 

type RevokePipelineReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevokePipelineReply) Descriptor 

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

func (*RevokePipelineReply) GetReason 

func (m *RevokePipelineReply) GetReason() string

func (*RevokePipelineReply) GetSuccess 

func (m *RevokePipelineReply) GetSuccess() bool

func (*RevokePipelineReply) ProtoMessage 

func (*RevokePipelineReply) ProtoMessage()

func (*RevokePipelineReply) Reset 

func (m *RevokePipelineReply) Reset()

func (*RevokePipelineReply) String 

func (m *RevokePipelineReply) String() string

func (*RevokePipelineReply) XXX_DiscardUnknown 

func (m *RevokePipelineReply) XXX_DiscardUnknown()

func (*RevokePipelineReply) XXX_Marshal 

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

func (*RevokePipelineReply) XXX_Merge 

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

func (*RevokePipelineReply) XXX_Size 

func (m *RevokePipelineReply) XXX_Size() int

func (*RevokePipelineReply) XXX_Unmarshal 

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

type RevokePipelineRequest 

type RevokePipelineRequest struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	PipelineID           uint64   `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RevokePipelineRequest) Descriptor 

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

func (*RevokePipelineRequest) GetClientID 

func (m *RevokePipelineRequest) GetClientID() string

func (*RevokePipelineRequest) GetPipelineID 

func (m *RevokePipelineRequest) GetPipelineID() uint64

func (*RevokePipelineRequest) ProtoMessage 

func (*RevokePipelineRequest) ProtoMessage()

func (*RevokePipelineRequest) Reset 

func (m *RevokePipelineRequest) Reset()

func (*RevokePipelineRequest) String 

func (m *RevokePipelineRequest) String() string

func (*RevokePipelineRequest) XXX_DiscardUnknown 

func (m *RevokePipelineRequest) XXX_DiscardUnknown()

func (*RevokePipelineRequest) XXX_Marshal 

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

func (*RevokePipelineRequest) XXX_Merge 

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

func (*RevokePipelineRequest) XXX_Size 

func (m *RevokePipelineRequest) XXX_Size() int

func (*RevokePipelineRequest) XXX_Unmarshal 

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

type SubscribeToCollectionsReply 

type SubscribeToCollectionsReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Collections          []string `protobuf:"bytes,3,rep,name=Collections,proto3" json:"Collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeToCollectionsReply) Descriptor 

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

func (*SubscribeToCollectionsReply) GetCollections 

func (m *SubscribeToCollectionsReply) GetCollections() []string

func (*SubscribeToCollectionsReply) GetReason 

func (m *SubscribeToCollectionsReply) GetReason() string

func (*SubscribeToCollectionsReply) GetSuccess 

func (m *SubscribeToCollectionsReply) GetSuccess() bool

func (*SubscribeToCollectionsReply) ProtoMessage 

func (*SubscribeToCollectionsReply) ProtoMessage()

func (*SubscribeToCollectionsReply) Reset 

func (m *SubscribeToCollectionsReply) Reset()

func (*SubscribeToCollectionsReply) String 

func (m *SubscribeToCollectionsReply) String() string

func (*SubscribeToCollectionsReply) XXX_DiscardUnknown 

func (m *SubscribeToCollectionsReply) XXX_DiscardUnknown()

func (*SubscribeToCollectionsReply) XXX_Marshal 

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

func (*SubscribeToCollectionsReply) XXX_Merge 

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

func (*SubscribeToCollectionsReply) XXX_Size 

func (m *SubscribeToCollectionsReply) XXX_Size() int

func (*SubscribeToCollectionsReply) XXX_Unmarshal 

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

type SubscribeToCollectionsRequest 

type SubscribeToCollectionsRequest struct {
	SubscriberID         string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	Collections          []string `protobuf:"bytes,2,rep,name=Collections,proto3" json:"Collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeToCollectionsRequest) Descriptor 

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

func (*SubscribeToCollectionsRequest) GetCollections 

func (m *SubscribeToCollectionsRequest) GetCollections() []string

func (*SubscribeToCollectionsRequest) GetSubscriberID 

func (m *SubscribeToCollectionsRequest) GetSubscriberID() string

func (*SubscribeToCollectionsRequest) ProtoMessage 

func (*SubscribeToCollectionsRequest) ProtoMessage()

func (*SubscribeToCollectionsRequest) Reset 

func (m *SubscribeToCollectionsRequest) Reset()

func (*SubscribeToCollectionsRequest) String 

func (m *SubscribeToCollectionsRequest) String() string

func (*SubscribeToCollectionsRequest) XXX_DiscardUnknown 

func (m *SubscribeToCollectionsRequest) XXX_DiscardUnknown()

func (*SubscribeToCollectionsRequest) XXX_Marshal 

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

func (*SubscribeToCollectionsRequest) XXX_Merge 

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

func (*SubscribeToCollectionsRequest) XXX_Size 

func (m *SubscribeToCollectionsRequest) XXX_Size() int

func (*SubscribeToCollectionsRequest) XXX_Unmarshal 

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

type SynchronizerClient 

type SynchronizerClient interface {
}

SynchronizerClient is the client API for Synchronizer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSynchronizerClient 

func NewSynchronizerClient(cc *grpc.ClientConn) SynchronizerClient

type SynchronizerServer 

type SynchronizerServer interface {
}

SynchronizerServer is the server API for Synchronizer service.

type UnimplementedSynchronizerServer 

type UnimplementedSynchronizerServer struct {
}

UnimplementedSynchronizerServer can be embedded to have forward compatible implementations.

type UnregisterSubscriberReply 

type UnregisterSubscriberReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterSubscriberReply) Descriptor 

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

func (*UnregisterSubscriberReply) GetReason 

func (m *UnregisterSubscriberReply) GetReason() string

func (*UnregisterSubscriberReply) GetSuccess 

func (m *UnregisterSubscriberReply) GetSuccess() bool

func (*UnregisterSubscriberReply) ProtoMessage 

func (*UnregisterSubscriberReply) ProtoMessage()

func (*UnregisterSubscriberReply) Reset 

func (m *UnregisterSubscriberReply) Reset()

func (*UnregisterSubscriberReply) String 

func (m *UnregisterSubscriberReply) String() string

func (*UnregisterSubscriberReply) XXX_DiscardUnknown 

func (m *UnregisterSubscriberReply) XXX_DiscardUnknown()

func (*UnregisterSubscriberReply) XXX_Marshal 

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

func (*UnregisterSubscriberReply) XXX_Merge 

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

func (*UnregisterSubscriberReply) XXX_Size 

func (m *UnregisterSubscriberReply) XXX_Size() int

func (*UnregisterSubscriberReply) XXX_Unmarshal 

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

type UnregisterSubscriberRequest 

type UnregisterSubscriberRequest struct {
	SubscriberID         string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterSubscriberRequest) Descriptor 

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

func (*UnregisterSubscriberRequest) GetSubscriberID 

func (m *UnregisterSubscriberRequest) GetSubscriberID() string

func (*UnregisterSubscriberRequest) ProtoMessage 

func (*UnregisterSubscriberRequest) ProtoMessage()

func (*UnregisterSubscriberRequest) Reset 

func (m *UnregisterSubscriberRequest) Reset()

func (*UnregisterSubscriberRequest) String 

func (m *UnregisterSubscriberRequest) String() string

func (*UnregisterSubscriberRequest) XXX_DiscardUnknown 

func (m *UnregisterSubscriberRequest) XXX_DiscardUnknown()

func (*UnregisterSubscriberRequest) XXX_Marshal 

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

func (*UnregisterSubscriberRequest) XXX_Merge 

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

func (*UnregisterSubscriberRequest) XXX_Size 

func (m *UnregisterSubscriberRequest) XXX_Size() int

func (*UnregisterSubscriberRequest) XXX_Unmarshal 

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

type UnsubscribeFromCollectionsReply 

type UnsubscribeFromCollectionsReply struct {
	Collections          []string `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnsubscribeFromCollectionsReply) Descriptor 

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

func (*UnsubscribeFromCollectionsReply) GetCollections 

func (m *UnsubscribeFromCollectionsReply) GetCollections() []string

func (*UnsubscribeFromCollectionsReply) ProtoMessage 

func (*UnsubscribeFromCollectionsReply) ProtoMessage()

func (*UnsubscribeFromCollectionsReply) Reset 

func (m *UnsubscribeFromCollectionsReply) Reset()

func (*UnsubscribeFromCollectionsReply) String 

func (m *UnsubscribeFromCollectionsReply) String() string

func (*UnsubscribeFromCollectionsReply) XXX_DiscardUnknown 

func (m *UnsubscribeFromCollectionsReply) XXX_DiscardUnknown()

func (*UnsubscribeFromCollectionsReply) XXX_Marshal 

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

func (*UnsubscribeFromCollectionsReply) XXX_Merge 

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

func (*UnsubscribeFromCollectionsReply) XXX_Size 

func (m *UnsubscribeFromCollectionsReply) XXX_Size() int

func (*UnsubscribeFromCollectionsReply) XXX_Unmarshal 

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

type UnsubscribeFromCollectionsRequest 

type UnsubscribeFromCollectionsRequest struct {
	SubscriberID         string   `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"`
	Collections          []string `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnsubscribeFromCollectionsRequest) Descriptor 

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

func (*UnsubscribeFromCollectionsRequest) GetCollections 

func (m *UnsubscribeFromCollectionsRequest) GetCollections() []string

func (*UnsubscribeFromCollectionsRequest) GetSubscriberID 

func (m *UnsubscribeFromCollectionsRequest) GetSubscriberID() string

func (*UnsubscribeFromCollectionsRequest) ProtoMessage 

func (*UnsubscribeFromCollectionsRequest) ProtoMessage()

func (*UnsubscribeFromCollectionsRequest) Reset 

func (m *UnsubscribeFromCollectionsRequest) Reset()

func (*UnsubscribeFromCollectionsRequest) String 

func (m *UnsubscribeFromCollectionsRequest) String() string

func (*UnsubscribeFromCollectionsRequest) XXX_DiscardUnknown 

func (m *UnsubscribeFromCollectionsRequest) XXX_DiscardUnknown()

func (*UnsubscribeFromCollectionsRequest) XXX_Marshal 

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

func (*UnsubscribeFromCollectionsRequest) XXX_Merge 

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

func (*UnsubscribeFromCollectionsRequest) XXX_Size 

func (m *UnsubscribeFromCollectionsRequest) XXX_Size() int

func (*UnsubscribeFromCollectionsRequest) XXX_Unmarshal 

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

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.