publish

package
v0.0.0-...-2aa8555 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrCode_name = map[int32]string{
	0: "ErrOK",
	1: "ErrNoSubScribers",
	2: "ErrInternalError",
}
View Source 
var ErrCode_value = map[string]int32{
	"ErrOK":            0,
	"ErrNoSubScribers": 1,
	"ErrInternalError": 2,
}

Functions

func RegisterPublishServiceServer 

func RegisterPublishServiceServer(s *grpc.Server, srv PublishServiceServer)

Types

type DeleteQueueReply 

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

func (*DeleteQueueReply) Descriptor 

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

func (*DeleteQueueReply) ProtoMessage 

func (*DeleteQueueReply) ProtoMessage()

func (*DeleteQueueReply) Reset 

func (m *DeleteQueueReply) Reset()

func (*DeleteQueueReply) String 

func (m *DeleteQueueReply) String() string

func (*DeleteQueueReply) XXX_DiscardUnknown 

func (m *DeleteQueueReply) XXX_DiscardUnknown()

func (*DeleteQueueReply) XXX_Marshal 

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

func (*DeleteQueueReply) XXX_Merge 

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

func (*DeleteQueueReply) XXX_Size 

func (m *DeleteQueueReply) XXX_Size() int

func (*DeleteQueueReply) XXX_Unmarshal 

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

type DeleteQueueRequest 

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

func (*DeleteQueueRequest) Descriptor 

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

func (*DeleteQueueRequest) GetTopic 

func (m *DeleteQueueRequest) GetTopic() string

func (*DeleteQueueRequest) ProtoMessage 

func (*DeleteQueueRequest) ProtoMessage()

func (*DeleteQueueRequest) Reset 

func (m *DeleteQueueRequest) Reset()

func (*DeleteQueueRequest) String 

func (m *DeleteQueueRequest) String() string

func (*DeleteQueueRequest) XXX_DiscardUnknown 

func (m *DeleteQueueRequest) XXX_DiscardUnknown()

func (*DeleteQueueRequest) XXX_Marshal 

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

func (*DeleteQueueRequest) XXX_Merge 

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

func (*DeleteQueueRequest) XXX_Size 

func (m *DeleteQueueRequest) XXX_Size() int

func (*DeleteQueueRequest) XXX_Unmarshal 

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

type ErrCode 

type ErrCode int32
const (
	ErrCode_ErrOK            ErrCode = 0
	ErrCode_ErrNoSubScribers ErrCode = 1
	ErrCode_ErrInternalError ErrCode = 2
)

func (ErrCode) EnumDescriptor 

func (ErrCode) EnumDescriptor() ([]byte, []int)

func (ErrCode) String 

func (x ErrCode) String() string

type PublishReply 

type PublishReply struct {
	ReturnCode           ErrCode   `protobuf:"varint,1,opt,name=ReturnCode,proto3,enum=publish.ErrCode" json:"ReturnCode,omitempty"`
	Results              []ErrCode `protobuf:"varint,2,rep,packed,name=Results,proto3,enum=publish.ErrCode" json:"Results,omitempty"`
	Cursor               [][]byte  `protobuf:"bytes,3,rep,name=Cursor,proto3" json:"Cursor,omitempty"`
	Cookie               []byte    `protobuf:"bytes,4,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PublishReply) Descriptor 

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

func (*PublishReply) GetCookie 

func (m *PublishReply) GetCookie() []byte

func (*PublishReply) GetCursor 

func (m *PublishReply) GetCursor() [][]byte

func (*PublishReply) GetResults 

func (m *PublishReply) GetResults() []ErrCode

func (*PublishReply) GetReturnCode 

func (m *PublishReply) GetReturnCode() ErrCode

func (*PublishReply) ProtoMessage 

func (*PublishReply) ProtoMessage()

func (*PublishReply) Reset 

func (m *PublishReply) Reset()

func (*PublishReply) String 

func (m *PublishReply) String() string

func (*PublishReply) XXX_DiscardUnknown 

func (m *PublishReply) XXX_DiscardUnknown()

func (*PublishReply) XXX_Marshal 

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

func (*PublishReply) XXX_Merge 

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

func (*PublishReply) XXX_Size 

func (m *PublishReply) XXX_Size() int

func (*PublishReply) XXX_Unmarshal 

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

type PublishRequest 

type PublishRequest struct {
	MessageID            []byte    `protobuf:"bytes,1,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	Payload              []byte    `protobuf:"bytes,2,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Targets              []*Target `protobuf:"bytes,3,rep,name=Targets,proto3" json:"Targets,omitempty"`
	Weight               int32     `protobuf:"varint,4,opt,name=Weight,proto3" json:"Weight,omitempty"`
	StatLabel            string    `protobuf:"bytes,5,opt,name=StatLabel,proto3" json:"StatLabel,omitempty"`
	TTL                  int32     `protobuf:"varint,6,opt,name=TTL,proto3" json:"TTL,omitempty"`
	AppKey               string    `protobuf:"bytes,7,opt,name=AppKey,proto3" json:"AppKey,omitempty"`
	Cookie               []byte    `protobuf:"bytes,8,opt,name=Cookie,proto3" json:"Cookie,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PublishRequest) Descriptor 

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

func (*PublishRequest) GetAppKey 

func (m *PublishRequest) GetAppKey() string

func (*PublishRequest) GetCookie 

func (m *PublishRequest) GetCookie() []byte

func (*PublishRequest) GetMessageID 

func (m *PublishRequest) GetMessageID() []byte

func (*PublishRequest) GetPayload 

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

func (*PublishRequest) GetStatLabel 

func (m *PublishRequest) GetStatLabel() string

func (*PublishRequest) GetTTL 

func (m *PublishRequest) GetTTL() int32

func (*PublishRequest) GetTargets 

func (m *PublishRequest) GetTargets() []*Target

func (*PublishRequest) GetWeight 

func (m *PublishRequest) GetWeight() int32

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset 

func (m *PublishRequest) Reset()

func (*PublishRequest) String 

func (m *PublishRequest) String() string

func (*PublishRequest) XXX_DiscardUnknown 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal 

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

func (*PublishRequest) XXX_Merge 

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

func (*PublishRequest) XXX_Size 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal 

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

type PublishServiceClient 

type PublishServiceClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error)
	DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*DeleteQueueReply, error)
}

PublishServiceClient is the client API for PublishService service.

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

func NewPublishServiceClient 

func NewPublishServiceClient(cc *grpc.ClientConn) PublishServiceClient

type PublishServiceServer 

type PublishServiceServer interface {
	Publish(context.Context, *PublishRequest) (*PublishReply, error)
	DeleteQueue(context.Context, *DeleteQueueRequest) (*DeleteQueueReply, error)
}

PublishServiceServer is the server API for PublishService service.

type Target 

type Target struct {
	Topic    string `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Qos      int32  `protobuf:"varint,4,opt,name=Qos,proto3" json:"Qos,omitempty"`
	IsRetain bool   `protobuf:"varint,5,opt,name=IsRetain,proto3" json:"IsRetain,omitempty"`
	// fase:  bifrost can drop this message if necessary
	// true:  bifrost will send this message to all clients that
	//        subscribed this topic.
	// Note: if set the NoneDowngrade to true, the corresponding message
	// might block the later message(when too many clients subscribed
	// this topic)
	NoneDowngrade        bool     `protobuf:"varint,6,opt,name=NoneDowngrade,proto3" json:"NoneDowngrade,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Target) Descriptor 

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

func (*Target) GetIsRetain 

func (m *Target) GetIsRetain() bool

func (*Target) GetNoneDowngrade 

func (m *Target) GetNoneDowngrade() bool

func (*Target) GetQos 

func (m *Target) GetQos() int32

func (*Target) GetTopic 

func (m *Target) GetTopic() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) Reset 

func (m *Target) Reset()

func (*Target) String 

func (m *Target) String() string

func (*Target) XXX_DiscardUnknown 

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal 

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

func (*Target) XXX_Merge 

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

func (*Target) XXX_Size 

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal 

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

type UnimplementedPublishServiceServer 

type UnimplementedPublishServiceServer struct {
}

UnimplementedPublishServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublishServiceServer) DeleteQueue 

func (*UnimplementedPublishServiceServer) DeleteQueue(ctx context.Context, req *DeleteQueueRequest) (*DeleteQueueReply, error)

func (*UnimplementedPublishServiceServer) Publish 

func (*UnimplementedPublishServiceServer) Publish(ctx context.Context, req *PublishRequest) (*PublishReply, 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.