pb

package
v0.0.70 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2019 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrSubscriptionNotFound = errors.New("subscription not found in store")
)

Functions

func RegisterSubscriptionsServiceServer 

func RegisterSubscriptionsServiceServer(s *grpc.Server, srv SubscriptionsServiceServer)

Types

type Client 

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

func NewClient 

func NewClient(conn *grpc.ClientConn) *Client

func (*Client) All 

func (c *Client) All(ctx context.Context) ([]*Metadata, error)

func (*Client) ByID 

func (c *Client) ByID(ctx context.Context, id string) (*Metadata, error)

func (*Client) ByPeer 

func (c *Client) ByPeer(ctx context.Context, id string) ([]*Metadata, error)

func (*Client) BySession 

func (c *Client) BySession(ctx context.Context, id string) ([]*Metadata, error)

func (*Client) ByTopic 

func (c *Client) ByTopic(ctx context.Context, tenant string, pattern []byte) ([]*Metadata, error)

func (*Client) Create 

func (c *Client) Create(ctx context.Context, input SubscriptionCreateInput) error

func (*Client) Delete 

func (c *Client) Delete(ctx context.Context, id string) error

type Metadata 

type Metadata struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	SessionID            string   `protobuf:"bytes,2,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	Tenant               string   `protobuf:"bytes,3,opt,name=Tenant,proto3" json:"Tenant,omitempty"`
	Pattern              []byte   `protobuf:"bytes,4,opt,name=Pattern,proto3" json:"Pattern,omitempty"`
	Qos                  int32    `protobuf:"varint,5,opt,name=Qos,proto3" json:"Qos,omitempty"`
	Peer                 string   `protobuf:"bytes,6,opt,name=Peer,proto3" json:"Peer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metadata) Descriptor 

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

func (*Metadata) GetID 

func (m *Metadata) GetID() string

func (*Metadata) GetPattern 

func (m *Metadata) GetPattern() []byte

func (*Metadata) GetPeer 

func (m *Metadata) GetPeer() string

func (*Metadata) GetQos 

func (m *Metadata) GetQos() int32

func (*Metadata) GetSessionID 

func (m *Metadata) GetSessionID() string

func (*Metadata) GetTenant 

func (m *Metadata) GetTenant() string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type SubscriptionByIDInput 

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

func (*SubscriptionByIDInput) Descriptor 

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

func (*SubscriptionByIDInput) GetID 

func (m *SubscriptionByIDInput) GetID() string

func (*SubscriptionByIDInput) ProtoMessage 

func (*SubscriptionByIDInput) ProtoMessage()

func (*SubscriptionByIDInput) Reset 

func (m *SubscriptionByIDInput) Reset()

func (*SubscriptionByIDInput) String 

func (m *SubscriptionByIDInput) String() string

func (*SubscriptionByIDInput) XXX_DiscardUnknown 

func (m *SubscriptionByIDInput) XXX_DiscardUnknown()

func (*SubscriptionByIDInput) XXX_Marshal 

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

func (*SubscriptionByIDInput) XXX_Merge 

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

func (*SubscriptionByIDInput) XXX_Size 

func (m *SubscriptionByIDInput) XXX_Size() int

func (*SubscriptionByIDInput) XXX_Unmarshal 

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

type SubscriptionByPeerInput 

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

func (*SubscriptionByPeerInput) Descriptor 

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

func (*SubscriptionByPeerInput) GetPeerID 

func (m *SubscriptionByPeerInput) GetPeerID() string

func (*SubscriptionByPeerInput) ProtoMessage 

func (*SubscriptionByPeerInput) ProtoMessage()

func (*SubscriptionByPeerInput) Reset 

func (m *SubscriptionByPeerInput) Reset()

func (*SubscriptionByPeerInput) String 

func (m *SubscriptionByPeerInput) String() string

func (*SubscriptionByPeerInput) XXX_DiscardUnknown 

func (m *SubscriptionByPeerInput) XXX_DiscardUnknown()

func (*SubscriptionByPeerInput) XXX_Marshal 

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

func (*SubscriptionByPeerInput) XXX_Merge 

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

func (*SubscriptionByPeerInput) XXX_Size 

func (m *SubscriptionByPeerInput) XXX_Size() int

func (*SubscriptionByPeerInput) XXX_Unmarshal 

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

type SubscriptionBySessionInput 

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

func (*SubscriptionBySessionInput) Descriptor 

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

func (*SubscriptionBySessionInput) GetSessionID 

func (m *SubscriptionBySessionInput) GetSessionID() string

func (*SubscriptionBySessionInput) ProtoMessage 

func (*SubscriptionBySessionInput) ProtoMessage()

func (*SubscriptionBySessionInput) Reset 

func (m *SubscriptionBySessionInput) Reset()

func (*SubscriptionBySessionInput) String 

func (m *SubscriptionBySessionInput) String() string

func (*SubscriptionBySessionInput) XXX_DiscardUnknown 

func (m *SubscriptionBySessionInput) XXX_DiscardUnknown()

func (*SubscriptionBySessionInput) XXX_Marshal 

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

func (*SubscriptionBySessionInput) XXX_Merge 

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

func (*SubscriptionBySessionInput) XXX_Size 

func (m *SubscriptionBySessionInput) XXX_Size() int

func (*SubscriptionBySessionInput) XXX_Unmarshal 

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

type SubscriptionByTopicInput 

type SubscriptionByTopicInput struct {
	Topic                []byte   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Tenant               string   `protobuf:"bytes,2,opt,name=Tenant,proto3" json:"Tenant,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscriptionByTopicInput) Descriptor 

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

func (*SubscriptionByTopicInput) GetTenant 

func (m *SubscriptionByTopicInput) GetTenant() string

func (*SubscriptionByTopicInput) GetTopic 

func (m *SubscriptionByTopicInput) GetTopic() []byte

func (*SubscriptionByTopicInput) ProtoMessage 

func (*SubscriptionByTopicInput) ProtoMessage()

func (*SubscriptionByTopicInput) Reset 

func (m *SubscriptionByTopicInput) Reset()

func (*SubscriptionByTopicInput) String 

func (m *SubscriptionByTopicInput) String() string

func (*SubscriptionByTopicInput) XXX_DiscardUnknown 

func (m *SubscriptionByTopicInput) XXX_DiscardUnknown()

func (*SubscriptionByTopicInput) XXX_Marshal 

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

func (*SubscriptionByTopicInput) XXX_Merge 

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

func (*SubscriptionByTopicInput) XXX_Size 

func (m *SubscriptionByTopicInput) XXX_Size() int

func (*SubscriptionByTopicInput) XXX_Unmarshal 

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

type SubscriptionCreateInput 

type SubscriptionCreateInput struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	SessionID            string   `protobuf:"bytes,2,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	Tenant               string   `protobuf:"bytes,3,opt,name=Tenant,proto3" json:"Tenant,omitempty"`
	Pattern              []byte   `protobuf:"bytes,4,opt,name=Pattern,proto3" json:"Pattern,omitempty"`
	Qos                  int32    `protobuf:"varint,5,opt,name=Qos,proto3" json:"Qos,omitempty"`
	Peer                 string   `protobuf:"bytes,6,opt,name=Peer,proto3" json:"Peer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscriptionCreateInput) Descriptor 

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

func (*SubscriptionCreateInput) GetID 

func (m *SubscriptionCreateInput) GetID() string

func (*SubscriptionCreateInput) GetPattern 

func (m *SubscriptionCreateInput) GetPattern() []byte

func (*SubscriptionCreateInput) GetPeer 

func (m *SubscriptionCreateInput) GetPeer() string

func (*SubscriptionCreateInput) GetQos 

func (m *SubscriptionCreateInput) GetQos() int32

func (*SubscriptionCreateInput) GetSessionID 

func (m *SubscriptionCreateInput) GetSessionID() string

func (*SubscriptionCreateInput) GetTenant 

func (m *SubscriptionCreateInput) GetTenant() string

func (*SubscriptionCreateInput) ProtoMessage 

func (*SubscriptionCreateInput) ProtoMessage()

func (*SubscriptionCreateInput) Reset 

func (m *SubscriptionCreateInput) Reset()

func (*SubscriptionCreateInput) String 

func (m *SubscriptionCreateInput) String() string

func (*SubscriptionCreateInput) XXX_DiscardUnknown 

func (m *SubscriptionCreateInput) XXX_DiscardUnknown()

func (*SubscriptionCreateInput) XXX_Marshal 

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

func (*SubscriptionCreateInput) XXX_Merge 

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

func (*SubscriptionCreateInput) XXX_Size 

func (m *SubscriptionCreateInput) XXX_Size() int

func (*SubscriptionCreateInput) XXX_Unmarshal 

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

type SubscriptionCreateOutput 

type SubscriptionCreateOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscriptionCreateOutput) Descriptor 

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

func (*SubscriptionCreateOutput) ProtoMessage 

func (*SubscriptionCreateOutput) ProtoMessage()

func (*SubscriptionCreateOutput) Reset 

func (m *SubscriptionCreateOutput) Reset()

func (*SubscriptionCreateOutput) String 

func (m *SubscriptionCreateOutput) String() string

func (*SubscriptionCreateOutput) XXX_DiscardUnknown 

func (m *SubscriptionCreateOutput) XXX_DiscardUnknown()

func (*SubscriptionCreateOutput) XXX_Marshal 

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

func (*SubscriptionCreateOutput) XXX_Merge 

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

func (*SubscriptionCreateOutput) XXX_Size 

func (m *SubscriptionCreateOutput) XXX_Size() int

func (*SubscriptionCreateOutput) XXX_Unmarshal 

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

type SubscriptionDeleteInput 

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

func (*SubscriptionDeleteInput) Descriptor 

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

func (*SubscriptionDeleteInput) GetID 

func (m *SubscriptionDeleteInput) GetID() string

func (*SubscriptionDeleteInput) ProtoMessage 

func (*SubscriptionDeleteInput) ProtoMessage()

func (*SubscriptionDeleteInput) Reset 

func (m *SubscriptionDeleteInput) Reset()

func (*SubscriptionDeleteInput) String 

func (m *SubscriptionDeleteInput) String() string

func (*SubscriptionDeleteInput) XXX_DiscardUnknown 

func (m *SubscriptionDeleteInput) XXX_DiscardUnknown()

func (*SubscriptionDeleteInput) XXX_Marshal 

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

func (*SubscriptionDeleteInput) XXX_Merge 

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

func (*SubscriptionDeleteInput) XXX_Size 

func (m *SubscriptionDeleteInput) XXX_Size() int

func (*SubscriptionDeleteInput) XXX_Unmarshal 

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

type SubscriptionDeleteOutput 

type SubscriptionDeleteOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscriptionDeleteOutput) Descriptor 

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

func (*SubscriptionDeleteOutput) ProtoMessage 

func (*SubscriptionDeleteOutput) ProtoMessage()

func (*SubscriptionDeleteOutput) Reset 

func (m *SubscriptionDeleteOutput) Reset()

func (*SubscriptionDeleteOutput) String 

func (m *SubscriptionDeleteOutput) String() string

func (*SubscriptionDeleteOutput) XXX_DiscardUnknown 

func (m *SubscriptionDeleteOutput) XXX_DiscardUnknown()

func (*SubscriptionDeleteOutput) XXX_Marshal 

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

func (*SubscriptionDeleteOutput) XXX_Merge 

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

func (*SubscriptionDeleteOutput) XXX_Size 

func (m *SubscriptionDeleteOutput) XXX_Size() int

func (*SubscriptionDeleteOutput) XXX_Unmarshal 

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

type SubscriptionFilterInput 

type SubscriptionFilterInput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscriptionFilterInput) Descriptor 

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

func (*SubscriptionFilterInput) ProtoMessage 

func (*SubscriptionFilterInput) ProtoMessage()

func (*SubscriptionFilterInput) Reset 

func (m *SubscriptionFilterInput) Reset()

func (*SubscriptionFilterInput) String 

func (m *SubscriptionFilterInput) String() string

func (*SubscriptionFilterInput) XXX_DiscardUnknown 

func (m *SubscriptionFilterInput) XXX_DiscardUnknown()

func (*SubscriptionFilterInput) XXX_Marshal 

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

func (*SubscriptionFilterInput) XXX_Merge 

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

func (*SubscriptionFilterInput) XXX_Size 

func (m *SubscriptionFilterInput) XXX_Size() int

func (*SubscriptionFilterInput) XXX_Unmarshal 

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

type SubscriptionMetadataList 

type SubscriptionMetadataList struct {
	Metadatas            []*Metadata `protobuf:"bytes,1,rep,name=Metadatas,proto3" json:"Metadatas,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SubscriptionMetadataList) Descriptor 

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

func (*SubscriptionMetadataList) GetMetadatas 

func (m *SubscriptionMetadataList) GetMetadatas() []*Metadata

func (*SubscriptionMetadataList) ProtoMessage 

func (*SubscriptionMetadataList) ProtoMessage()

func (*SubscriptionMetadataList) Reset 

func (m *SubscriptionMetadataList) Reset()

func (*SubscriptionMetadataList) String 

func (m *SubscriptionMetadataList) String() string

func (*SubscriptionMetadataList) XXX_DiscardUnknown 

func (m *SubscriptionMetadataList) XXX_DiscardUnknown()

func (*SubscriptionMetadataList) XXX_Marshal 

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

func (*SubscriptionMetadataList) XXX_Merge 

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

func (*SubscriptionMetadataList) XXX_Size 

func (m *SubscriptionMetadataList) XXX_Size() int

func (*SubscriptionMetadataList) XXX_Unmarshal 

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

type SubscriptionStateTransition 

type SubscriptionStateTransition struct {
	Kind                 string                                          `protobuf:"bytes,1,opt,name=Kind,proto3" json:"Kind,omitempty"`
	SubscriptionCreated  *SubscriptionStateTransitionSubscriptionCreated `protobuf:"bytes,2,opt,name=SubscriptionCreated,proto3" json:"SubscriptionCreated,omitempty"`
	SubscriptionDeleted  *SubscriptionStateTransitionSubscriptionDeleted `protobuf:"bytes,3,opt,name=SubscriptionDeleted,proto3" json:"SubscriptionDeleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
	XXX_unrecognized     []byte                                          `json:"-"`
	XXX_sizecache        int32                                           `json:"-"`
}

func (*SubscriptionStateTransition) Descriptor 

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

func (*SubscriptionStateTransition) GetKind 

func (m *SubscriptionStateTransition) GetKind() string

func (*SubscriptionStateTransition) GetSubscriptionCreated 

func (m *SubscriptionStateTransition) GetSubscriptionCreated() *SubscriptionStateTransitionSubscriptionCreated

func (*SubscriptionStateTransition) GetSubscriptionDeleted 

func (m *SubscriptionStateTransition) GetSubscriptionDeleted() *SubscriptionStateTransitionSubscriptionDeleted

func (*SubscriptionStateTransition) ProtoMessage 

func (*SubscriptionStateTransition) ProtoMessage()

func (*SubscriptionStateTransition) Reset 

func (m *SubscriptionStateTransition) Reset()

func (*SubscriptionStateTransition) String 

func (m *SubscriptionStateTransition) String() string

func (*SubscriptionStateTransition) XXX_DiscardUnknown 

func (m *SubscriptionStateTransition) XXX_DiscardUnknown()

func (*SubscriptionStateTransition) XXX_Marshal 

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

func (*SubscriptionStateTransition) XXX_Merge 

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

func (*SubscriptionStateTransition) XXX_Size 

func (m *SubscriptionStateTransition) XXX_Size() int

func (*SubscriptionStateTransition) XXX_Unmarshal 

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

type SubscriptionStateTransitionSubscriptionCreated 

type SubscriptionStateTransitionSubscriptionCreated struct {
	Input                *SubscriptionCreateInput `protobuf:"bytes,1,opt,name=Input,proto3" json:"Input,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*SubscriptionStateTransitionSubscriptionCreated) Descriptor 

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

func (*SubscriptionStateTransitionSubscriptionCreated) GetInput 

func (m *SubscriptionStateTransitionSubscriptionCreated) GetInput() *SubscriptionCreateInput

func (*SubscriptionStateTransitionSubscriptionCreated) ProtoMessage 

func (*SubscriptionStateTransitionSubscriptionCreated) ProtoMessage()

func (*SubscriptionStateTransitionSubscriptionCreated) Reset 

func (m *SubscriptionStateTransitionSubscriptionCreated) Reset()

func (*SubscriptionStateTransitionSubscriptionCreated) String 

func (m *SubscriptionStateTransitionSubscriptionCreated) String() string

func (*SubscriptionStateTransitionSubscriptionCreated) XXX_DiscardUnknown 

func (m *SubscriptionStateTransitionSubscriptionCreated) XXX_DiscardUnknown()

func (*SubscriptionStateTransitionSubscriptionCreated) XXX_Marshal 

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

func (*SubscriptionStateTransitionSubscriptionCreated) XXX_Merge 

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

func (*SubscriptionStateTransitionSubscriptionCreated) XXX_Size 

func (m *SubscriptionStateTransitionSubscriptionCreated) XXX_Size() int

func (*SubscriptionStateTransitionSubscriptionCreated) XXX_Unmarshal 

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

type SubscriptionStateTransitionSubscriptionDeleted 

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

func (*SubscriptionStateTransitionSubscriptionDeleted) Descriptor 

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

func (*SubscriptionStateTransitionSubscriptionDeleted) GetID 

func (m *SubscriptionStateTransitionSubscriptionDeleted) GetID() string

func (*SubscriptionStateTransitionSubscriptionDeleted) ProtoMessage 

func (*SubscriptionStateTransitionSubscriptionDeleted) ProtoMessage()

func (*SubscriptionStateTransitionSubscriptionDeleted) Reset 

func (m *SubscriptionStateTransitionSubscriptionDeleted) Reset()

func (*SubscriptionStateTransitionSubscriptionDeleted) String 

func (m *SubscriptionStateTransitionSubscriptionDeleted) String() string

func (*SubscriptionStateTransitionSubscriptionDeleted) XXX_DiscardUnknown 

func (m *SubscriptionStateTransitionSubscriptionDeleted) XXX_DiscardUnknown()

func (*SubscriptionStateTransitionSubscriptionDeleted) XXX_Marshal 

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

func (*SubscriptionStateTransitionSubscriptionDeleted) XXX_Merge 

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

func (*SubscriptionStateTransitionSubscriptionDeleted) XXX_Size 

func (m *SubscriptionStateTransitionSubscriptionDeleted) XXX_Size() int

func (*SubscriptionStateTransitionSubscriptionDeleted) XXX_Unmarshal 

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

type SubscriptionsServiceClient 

type SubscriptionsServiceClient interface {
	Create(ctx context.Context, in *SubscriptionCreateInput, opts ...grpc.CallOption) (*SubscriptionCreateOutput, error)
	Delete(ctx context.Context, in *SubscriptionDeleteInput, opts ...grpc.CallOption) (*SubscriptionDeleteOutput, error)
	ByID(ctx context.Context, in *SubscriptionByIDInput, opts ...grpc.CallOption) (*Metadata, error)
	BySession(ctx context.Context, in *SubscriptionBySessionInput, opts ...grpc.CallOption) (*SubscriptionMetadataList, error)
	ByPeer(ctx context.Context, in *SubscriptionByPeerInput, opts ...grpc.CallOption) (*SubscriptionMetadataList, error)
	ByTopic(ctx context.Context, in *SubscriptionByTopicInput, opts ...grpc.CallOption) (*SubscriptionMetadataList, error)
	All(ctx context.Context, in *SubscriptionFilterInput, opts ...grpc.CallOption) (*SubscriptionMetadataList, error)
}

SubscriptionsServiceClient is the client API for SubscriptionsService service.

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

func NewSubscriptionsServiceClient 

func NewSubscriptionsServiceClient(cc *grpc.ClientConn) SubscriptionsServiceClient

type SubscriptionsServiceServer 

type SubscriptionsServiceServer interface {
	Create(context.Context, *SubscriptionCreateInput) (*SubscriptionCreateOutput, error)
	Delete(context.Context, *SubscriptionDeleteInput) (*SubscriptionDeleteOutput, error)
	ByID(context.Context, *SubscriptionByIDInput) (*Metadata, error)
	BySession(context.Context, *SubscriptionBySessionInput) (*SubscriptionMetadataList, error)
	ByPeer(context.Context, *SubscriptionByPeerInput) (*SubscriptionMetadataList, error)
	ByTopic(context.Context, *SubscriptionByTopicInput) (*SubscriptionMetadataList, error)
	All(context.Context, *SubscriptionFilterInput) (*SubscriptionMetadataList, error)
}

SubscriptionsServiceServer is the server API for SubscriptionsService service.

type UnimplementedSubscriptionsServiceServer 

type UnimplementedSubscriptionsServiceServer struct {
}

UnimplementedSubscriptionsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriptionsServiceServer) All 

func (*UnimplementedSubscriptionsServiceServer) All(ctx context.Context, req *SubscriptionFilterInput) (*SubscriptionMetadataList, error)

func (*UnimplementedSubscriptionsServiceServer) ByID 

func (*UnimplementedSubscriptionsServiceServer) ByID(ctx context.Context, req *SubscriptionByIDInput) (*Metadata, error)

func (*UnimplementedSubscriptionsServiceServer) ByPeer 

func (*UnimplementedSubscriptionsServiceServer) ByPeer(ctx context.Context, req *SubscriptionByPeerInput) (*SubscriptionMetadataList, error)

func (*UnimplementedSubscriptionsServiceServer) BySession 

func (*UnimplementedSubscriptionsServiceServer) BySession(ctx context.Context, req *SubscriptionBySessionInput) (*SubscriptionMetadataList, error)

func (*UnimplementedSubscriptionsServiceServer) ByTopic 

func (*UnimplementedSubscriptionsServiceServer) ByTopic(ctx context.Context, req *SubscriptionByTopicInput) (*SubscriptionMetadataList, error)

func (*UnimplementedSubscriptionsServiceServer) Create 

func (*UnimplementedSubscriptionsServiceServer) Create(ctx context.Context, req *SubscriptionCreateInput) (*SubscriptionCreateOutput, error)

func (*UnimplementedSubscriptionsServiceServer) Delete 

func (*UnimplementedSubscriptionsServiceServer) Delete(ctx context.Context, req *SubscriptionDeleteInput) (*SubscriptionDeleteOutput, 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.