pb

package
v0.0.71 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2019 License: MPL-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SEP = byte('/')
)

Functions

func RegisterTopicsServiceServer 

func RegisterTopicsServiceServer(s *grpc.Server, srv TopicsServiceServer)

Types

type ByTopicPatternInput 

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

func (*ByTopicPatternInput) Descriptor 

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

func (*ByTopicPatternInput) GetPattern 

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

func (*ByTopicPatternInput) GetTenant 

func (m *ByTopicPatternInput) GetTenant() string

func (*ByTopicPatternInput) ProtoMessage 

func (*ByTopicPatternInput) ProtoMessage()

func (*ByTopicPatternInput) Reset 

func (m *ByTopicPatternInput) Reset()

func (*ByTopicPatternInput) String 

func (m *ByTopicPatternInput) String() string

func (*ByTopicPatternInput) XXX_DiscardUnknown 

func (m *ByTopicPatternInput) XXX_DiscardUnknown()

func (*ByTopicPatternInput) XXX_Marshal 

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

func (*ByTopicPatternInput) XXX_Merge 

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

func (*ByTopicPatternInput) XXX_Size 

func (m *ByTopicPatternInput) XXX_Size() int

func (*ByTopicPatternInput) XXX_Unmarshal 

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

type ByTopicPatternOutput 

type ByTopicPatternOutput struct {
	Messages             []*RetainedMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ByTopicPatternOutput) Descriptor 

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

func (*ByTopicPatternOutput) GetMessages 

func (m *ByTopicPatternOutput) GetMessages() []*RetainedMessage

func (*ByTopicPatternOutput) ProtoMessage 

func (*ByTopicPatternOutput) ProtoMessage()

func (*ByTopicPatternOutput) Reset 

func (m *ByTopicPatternOutput) Reset()

func (*ByTopicPatternOutput) String 

func (m *ByTopicPatternOutput) String() string

func (*ByTopicPatternOutput) XXX_DiscardUnknown 

func (m *ByTopicPatternOutput) XXX_DiscardUnknown()

func (*ByTopicPatternOutput) XXX_Marshal 

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

func (*ByTopicPatternOutput) XXX_Merge 

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

func (*ByTopicPatternOutput) XXX_Size 

func (m *ByTopicPatternOutput) XXX_Size() int

func (*ByTopicPatternOutput) XXX_Unmarshal 

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

type Client 

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

func NewClient 

func NewClient(conn *grpc.ClientConn) *Client

func (*Client) ByTopicPattern 

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

type RetainedMessage 

type RetainedMessage struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Tenant               string   `protobuf:"bytes,2,opt,name=Tenant,proto3" json:"Tenant,omitempty"`
	Topic                []byte   `protobuf:"bytes,3,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Payload              []byte   `protobuf:"bytes,4,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Qos                  int32    `protobuf:"varint,5,opt,name=Qos,proto3" json:"Qos,omitempty"`
	LastAdded            int64    `protobuf:"varint,6,opt,name=LastAdded,proto3" json:"LastAdded,omitempty"`
	LastDeleted          int64    `protobuf:"varint,7,opt,name=LastDeleted,proto3" json:"LastDeleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RetainedMessage) Descriptor 

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

func (*RetainedMessage) GetID 

func (m *RetainedMessage) GetID() string

func (*RetainedMessage) GetLastAdded 

func (m *RetainedMessage) GetLastAdded() int64

func (*RetainedMessage) GetLastDeleted 

func (m *RetainedMessage) GetLastDeleted() int64

func (*RetainedMessage) GetPayload 

func (m *RetainedMessage) GetPayload() []byte

func (*RetainedMessage) GetQos 

func (m *RetainedMessage) GetQos() int32

func (*RetainedMessage) GetTenant 

func (m *RetainedMessage) GetTenant() string

func (*RetainedMessage) GetTopic 

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

func (*RetainedMessage) ProtoMessage 

func (*RetainedMessage) ProtoMessage()

func (*RetainedMessage) Reset 

func (m *RetainedMessage) Reset()

func (*RetainedMessage) String 

func (m *RetainedMessage) String() string

func (*RetainedMessage) XXX_DiscardUnknown 

func (m *RetainedMessage) XXX_DiscardUnknown()

func (*RetainedMessage) XXX_Marshal 

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

func (*RetainedMessage) XXX_Merge 

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

func (*RetainedMessage) XXX_Size 

func (m *RetainedMessage) XXX_Size() int

func (*RetainedMessage) XXX_Unmarshal 

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

type RetainedMessageMetadataList 

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

func (*RetainedMessageMetadataList) Descriptor 

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

func (*RetainedMessageMetadataList) GetRetainedMessages 

func (m *RetainedMessageMetadataList) GetRetainedMessages() []*RetainedMessage

func (*RetainedMessageMetadataList) ProtoMessage 

func (*RetainedMessageMetadataList) ProtoMessage()

func (*RetainedMessageMetadataList) Reset 

func (m *RetainedMessageMetadataList) Reset()

func (*RetainedMessageMetadataList) String 

func (m *RetainedMessageMetadataList) String() string

func (*RetainedMessageMetadataList) XXX_DiscardUnknown 

func (m *RetainedMessageMetadataList) XXX_DiscardUnknown()

func (*RetainedMessageMetadataList) XXX_Marshal 

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

func (*RetainedMessageMetadataList) XXX_Merge 

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

func (*RetainedMessageMetadataList) XXX_Size 

func (m *RetainedMessageMetadataList) XXX_Size() int

func (*RetainedMessageMetadataList) XXX_Unmarshal 

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

type RetainedMessageSet 

type RetainedMessageSet []RetainedMessage

func (RetainedMessageSet) Apply 

func (set RetainedMessageSet) Apply(f func(s RetainedMessage))

func (RetainedMessageSet) ApplyE 

func (set RetainedMessageSet) ApplyE(f func(s RetainedMessage) error) error

func (RetainedMessageSet) ApplyIdx 

func (set RetainedMessageSet) ApplyIdx(f func(idx int, s RetainedMessage))

func (RetainedMessageSet) Filter 

func (set RetainedMessageSet) Filter(filters ...retainedMessageFilter) RetainedMessageSet

type Topic 

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

func NewTopic 

func NewTopic(topic []byte) *Topic

func (*Topic) Bytes 

func (t *Topic) Bytes() []byte

func (*Topic) Chop 

func (t *Topic) Chop() (*Topic, string, bool)

func (*Topic) Cur 

func (t *Topic) Cur() []byte

func (*Topic) Head 

func (t *Topic) Head() []byte

Head returns the previous tokens and separators

func (*Topic) Length 

func (t *Topic) Length() int

func (*Topic) Match 

func (t *Topic) Match(pattern []byte) bool

func (*Topic) Next 

func (t *Topic) Next() error

Next advances to the next token, and return the read token

func (*Topic) Tail 

func (t *Topic) Tail() []byte

Head returns the tokens and separators after the cursor

type TopicsServiceClient 

type TopicsServiceClient interface {
	ByTopicPattern(ctx context.Context, in *ByTopicPatternInput, opts ...grpc.CallOption) (*ByTopicPatternOutput, error)
}

TopicsServiceClient is the client API for TopicsService service.

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

func NewTopicsServiceClient 

func NewTopicsServiceClient(cc *grpc.ClientConn) TopicsServiceClient

type TopicsServiceServer 

type TopicsServiceServer interface {
	ByTopicPattern(context.Context, *ByTopicPatternInput) (*ByTopicPatternOutput, error)
}

TopicsServiceServer is the server API for TopicsService service.

type UnimplementedTopicsServiceServer 

type UnimplementedTopicsServiceServer struct {
}

UnimplementedTopicsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTopicsServiceServer) ByTopicPattern 

func (*UnimplementedTopicsServiceServer) ByTopicPattern(ctx context.Context, req *ByTopicPatternInput) (*ByTopicPatternOutput, 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.