broker

package

Go to main page

Versions in this module

v4

v4.0.0

Feb 15, 2022

retracted

GO-2023-1808 +2 more

GO-2023-1808: Go package pydio/cells vulnerable to authorization bypass in github.com/pydio/cells

GO-2023-1809: go package pydio cells vulnerable to cross-site scripting in github.com/pydio/cells

GO-2023-2344: Abstrium Pydio Cells Resource Injection vulnerability in github.com/pydio/cells

Changes in this version

+ var Broker_ServiceDesc = grpc.ServiceDesc

+ var File_cells_message_proto protoreflect.FileDescriptor

+ func DeregisterBrokerEnhancedServer(s grpc.ServiceRegistrar, name string)

+ func RegisterBrokerEnhancedServer(s grpc.ServiceRegistrar, srv NamedBrokerServer)

+ func RegisterBrokerServer(s grpc.ServiceRegistrar, srv BrokerServer)

+ type BrokerClient interface

+ Publish func(ctx context.Context, opts ...grpc.CallOption) (Broker_PublishClient, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Broker_SubscribeClient, error)

+ func NewBrokerClient(cc grpc.ClientConnInterface) BrokerClient

+ type BrokerEnhancedServer map[string]NamedBrokerServer

+ func (m BrokerEnhancedServer) Publish(s Broker_PublishServer) error

+ func (m BrokerEnhancedServer) Subscribe(r *SubscribeRequest, s Broker_SubscribeServer) error

+ type BrokerServer interface

+ Publish func(Broker_PublishServer) error

+ Subscribe func(*SubscribeRequest, Broker_SubscribeServer) error

+ type BrokerStub struct

+ func (s *BrokerStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error

+ func (s *BrokerStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)

+ type BrokerStub_PublishStreamer struct

+ func (s *BrokerStub_PublishStreamer) Recv() (*PublishRequest, error)

+ func (s *BrokerStub_PublishStreamer) Send(response *Empty) error

+ func (s *BrokerStub_PublishStreamer) SendAndClose(response *Empty) error

+ type BrokerStub_SubscribeStreamer struct

+ func (s *BrokerStub_SubscribeStreamer) Send(response *Messages) error

+ type Broker_PublishClient interface

+ CloseAndRecv func() (*Empty, error)

+ Send func(*PublishRequest) error

+ type Broker_PublishServer interface

+ Recv func() (*PublishRequest, error)

+ SendAndClose func(*Empty) error

+ type Broker_SubscribeClient interface

+ Recv func() (*Messages, error)

+ type Broker_SubscribeServer interface

+ Send func(*Messages) error

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (this *Empty) Validate() error

+ func (x *Empty) ProtoReflect() protoreflect.Message

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type Message struct

+ Body []byte

+ Header map[string]string

+ func (*Message) Descriptor() ([]byte, []int)

+ func (*Message) ProtoMessage()

+ func (this *Message) Validate() error

+ func (x *Message) GetBody() []byte

+ func (x *Message) GetHeader() map[string]string

+ func (x *Message) ProtoReflect() protoreflect.Message

+ func (x *Message) Reset()

+ func (x *Message) String() string

+ type Messages struct

+ Messages []*Message

+ func (*Messages) Descriptor() ([]byte, []int)

+ func (*Messages) ProtoMessage()

+ func (this *Messages) Validate() error

+ func (x *Messages) GetMessages() []*Message

+ func (x *Messages) ProtoReflect() protoreflect.Message

+ func (x *Messages) Reset()

+ func (x *Messages) String() string

+ type NamedBrokerServer interface

+ Name func() string

+ type PublishRequest struct

+ Messages *Messages

+ Topic string

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

+ func (*PublishRequest) ProtoMessage()

+ func (this *PublishRequest) Validate() error

+ func (x *PublishRequest) GetMessages() *Messages

+ func (x *PublishRequest) GetTopic() string

+ func (x *PublishRequest) ProtoReflect() protoreflect.Message

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type SubscribeRequest struct

+ Queue string

+ Topic string

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (this *SubscribeRequest) Validate() error

+ func (x *SubscribeRequest) GetQueue() string

+ func (x *SubscribeRequest) GetTopic() string

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type UnimplementedBrokerServer struct

+ func (UnimplementedBrokerServer) Publish(Broker_PublishServer) error

+ func (UnimplementedBrokerServer) Subscribe(*SubscribeRequest, Broker_SubscribeServer) error

+ type UnsafeBrokerServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL