broker

Documentation

Index

• type CandidateStatus
• type MessageQueueBroker
  • func NewMessageBroker(option *MessageQueueBrokerOption, grpcDialOption grpc.DialOption) (mqBroker *MessageQueueBroker, err error)
  • func (broker *MessageQueueBroker) AdjustedUrl(location *filer_pb.Location) string
  • func (broker *MessageQueueBroker) AssignSegmentBrokers(c context.Context, request *mq_pb.AssignSegmentBrokersRequest) (*mq_pb.AssignSegmentBrokersResponse, error)
  • func (broker *MessageQueueBroker) CheckBrokerLoad(c context.Context, request *mq_pb.CheckBrokerLoadRequest) (*mq_pb.CheckBrokerLoadResponse, error)
  • func (broker *MessageQueueBroker) CheckSegmentStatus(c context.Context, request *mq_pb.CheckSegmentStatusRequest) (*mq_pb.CheckSegmentStatusResponse, error)
  • func (broker *MessageQueueBroker) FindBrokerLeader(c context.Context, request *mq_pb.FindBrokerLeaderRequest) (*mq_pb.FindBrokerLeaderResponse, error)
  • func (broker *MessageQueueBroker) GetFiler() pb.ServerAddress
  • func (broker *MessageQueueBroker) OnBrokerUpdate(update *master_pb.ClusterNodeUpdate, startFrom time.Time)
  • func (broker *MessageQueueBroker) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error
• type MessageQueueBrokerOption

Types

type CandidateStatus

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

type MessageQueueBroker

type MessageQueueBroker struct {
	mq_pb.UnimplementedSeaweedMessagingServer

	MasterClient *wdclient.MasterClient
	// contains filtered or unexported fields
}

func NewMessageBroker

func NewMessageBroker(option *MessageQueueBrokerOption, grpcDialOption grpc.DialOption) (mqBroker *MessageQueueBroker, err error)

func (*MessageQueueBroker) AdjustedUrl

func (broker *MessageQueueBroker) AdjustedUrl(location *filer_pb.Location) string

func (*MessageQueueBroker) AssignSegmentBrokers

func (broker *MessageQueueBroker) AssignSegmentBrokers(c context.Context, request *mq_pb.AssignSegmentBrokersRequest) (*mq_pb.AssignSegmentBrokersResponse, error)

func (*MessageQueueBroker) CheckBrokerLoad

func (broker *MessageQueueBroker) CheckBrokerLoad(c context.Context, request *mq_pb.CheckBrokerLoadRequest) (*mq_pb.CheckBrokerLoadResponse, error)

func (*MessageQueueBroker) CheckSegmentStatus

func (broker *MessageQueueBroker) CheckSegmentStatus(c context.Context, request *mq_pb.CheckSegmentStatusRequest) (*mq_pb.CheckSegmentStatusResponse, error)

func (*MessageQueueBroker) FindBrokerLeader

func (broker *MessageQueueBroker) FindBrokerLeader(c context.Context, request *mq_pb.FindBrokerLeaderRequest) (*mq_pb.FindBrokerLeaderResponse, error)

func (*MessageQueueBroker) GetFiler

func (broker *MessageQueueBroker) GetFiler() pb.ServerAddress

func (*MessageQueueBroker) OnBrokerUpdate

func (broker *MessageQueueBroker) OnBrokerUpdate(update *master_pb.ClusterNodeUpdate, startFrom time.Time)

func (*MessageQueueBroker) WithFilerClient

func (broker *MessageQueueBroker) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) error

type MessageQueueBrokerOption

type MessageQueueBrokerOption struct {
	Masters            map[string]pb.ServerAddress
	FilerGroup         string
	DataCenter         string
	Rack               string
	DefaultReplication string
	MaxMB              int
	Ip                 string
	Port               int
	Cipher             bool
}