federation

type Broker struct {
	Plugins map[string]*Plugin `` /* 134-byte string literal not displayed */
}

type Config struct {
	Topics  map[string]*Topic  `` /* 132-byte string literal not displayed */
	Brokers map[string]*Broker `` /* 134-byte string literal not displayed */
}

type ConfigRequest struct {
}

type ConfigResponse struct {
	Config *Config `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
}

type FederationHandler interface {
	Config(context.Context, *ConfigRequest, *ConfigResponse) error
}

type FederationService interface {
	Config(ctx context.Context, in *ConfigRequest, opts ...client.CallOption) (*ConfigResponse, error)
}

type Plugin struct {
	Hosts []string `protobuf:"bytes,2,rep,name=hosts" json:"hosts,omitempty"`
}

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"`
}