Documentation ¶
Overview ¶
Package federation is a generated protocol buffer package.
It is generated from these files:
github.com/microhq/federation-srv/proto/federation/federation.proto
It has these top-level messages:
Config Topic Plugin Broker ConfigRequest ConfigResponse
Package federation is a generated protocol buffer package.
It is generated from these files:
github.com/microhq/federation-srv/proto/federation/federation.proto
It has these top-level messages:
Config Topic Plugin Broker ConfigRequest ConfigResponse
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterFederationHandler ¶
func RegisterFederationHandler(s server.Server, hdlr FederationHandler, opts ...server.HandlerOption) error
Types ¶
type Broker ¶
func (*Broker) Descriptor ¶
func (*Broker) GetPlugins ¶
func (*Broker) ProtoMessage ¶
func (*Broker) ProtoMessage()
type Config ¶
type Config struct { Topics map[string]*Topic `` /* 132-byte string literal not displayed */ Brokers map[string]*Broker `` /* 134-byte string literal not displayed */ }
func (*Config) Descriptor ¶
func (*Config) GetBrokers ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
type ConfigRequest ¶
type ConfigRequest struct { }
func (*ConfigRequest) Descriptor ¶
func (*ConfigRequest) Descriptor() ([]byte, []int)
func (*ConfigRequest) ProtoMessage ¶
func (*ConfigRequest) ProtoMessage()
func (*ConfigRequest) Reset ¶
func (m *ConfigRequest) Reset()
func (*ConfigRequest) String ¶
func (m *ConfigRequest) String() string
type ConfigResponse ¶
type ConfigResponse struct {
Config *Config `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
}
func (*ConfigResponse) Descriptor ¶
func (*ConfigResponse) Descriptor() ([]byte, []int)
func (*ConfigResponse) GetConfig ¶
func (m *ConfigResponse) GetConfig() *Config
func (*ConfigResponse) ProtoMessage ¶
func (*ConfigResponse) ProtoMessage()
func (*ConfigResponse) Reset ¶
func (m *ConfigResponse) Reset()
func (*ConfigResponse) String ¶
func (m *ConfigResponse) String() string
type FederationHandler ¶
type FederationHandler interface {
Config(context.Context, *ConfigRequest, *ConfigResponse) error
}
type FederationService ¶
type FederationService interface {
Config(ctx context.Context, in *ConfigRequest, opts ...client.CallOption) (*ConfigResponse, error)
}
func NewFederationService ¶
func NewFederationService(name string, c client.Client) FederationService
type Plugin ¶
type Plugin struct {
Hosts []string `protobuf:"bytes,2,rep,name=hosts" json:"hosts,omitempty"`
}
func (*Plugin) Descriptor ¶
func (*Plugin) ProtoMessage ¶
func (*Plugin) ProtoMessage()
type Topic ¶
type Topic struct { Rate float64 `protobuf:"fixed64,1,opt,name=rate" json:"rate,omitempty"` Publish []string `protobuf:"bytes,2,rep,name=publish" json:"publish,omitempty"` Subscribe []string `protobuf:"bytes,3,rep,name=subscribe" json:"subscribe,omitempty"` }
func (*Topic) Descriptor ¶
func (*Topic) GetPublish ¶
func (*Topic) GetSubscribe ¶
func (*Topic) ProtoMessage ¶
func (*Topic) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.