api

package
v0.0.0-...-ef9407b Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

README

Building

protoc --go_out=plugins=grpc:. *.proto

Documentation

Overview

Package api is a generated protocol buffer package.

It is generated from these files: 

api.proto

It has these top-level messages: 

VersionRequest
VersionReply
BrokerRequest
BrokerReply
ClientsRequest
ClientsReply
ClientInfo
AdminsRequest
AdminsReply
ClusterRequest
ClusterReply
RoutesRequest
RoutesReply
RouteInfo
StatusRequest
StatusReply
PluginsRequest
PluginsReply
ServicesRequest
ServicesReply
ServiceInfo
SubscriptionsRequest
SubscriptionsReply
SubscriptionInfo
SessionsRequest
SessionsReply
SessionInfo
TopicsRequest
TopicsReply
TopicInfo
ReplyMessageHeader

Index

Constants

This section is empty.

Variables

View Source 
var Configs = map[string]string{
	"listen":   "localhost:50051",
	"loglevel": "debug",
}

Functions

func RegisterApiServer 

func RegisterApiServer(s *grpc.Server, srv ApiServer)

Types

type AdminsReply 

type AdminsReply struct {
}

func (*AdminsReply) Descriptor 

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

func (*AdminsReply) ProtoMessage 

func (*AdminsReply) ProtoMessage()

func (*AdminsReply) Reset 

func (m *AdminsReply) Reset()

func (*AdminsReply) String 

func (m *AdminsReply) String() string

type AdminsRequest 

type AdminsRequest struct {
}

func (*AdminsRequest) Descriptor 

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

func (*AdminsRequest) ProtoMessage 

func (*AdminsRequest) ProtoMessage()

func (*AdminsRequest) Reset 

func (m *AdminsRequest) Reset()

func (*AdminsRequest) String 

func (m *AdminsRequest) String() string

type ApiClient 

type ApiClient interface {
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionReply, error)
	Admins(ctx context.Context, in *AdminsRequest, opts ...grpc.CallOption) (*AdminsReply, error)
	Cluster(ctx context.Context, in *ClusterRequest, opts ...grpc.CallOption) (*ClusterReply, error)
	Routes(ctx context.Context, in *RoutesRequest, opts ...grpc.CallOption) (*RoutesReply, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusReply, error)
	Broker(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*BrokerReply, error)
	Plugins(ctx context.Context, in *PluginsRequest, opts ...grpc.CallOption) (*PluginsReply, error)
	Services(ctx context.Context, in *ServicesRequest, opts ...grpc.CallOption) (*ServicesReply, error)
	Subscriptions(ctx context.Context, in *SubscriptionsRequest, opts ...grpc.CallOption) (*SubscriptionsReply, error)
	Clients(ctx context.Context, in *ClientsRequest, opts ...grpc.CallOption) (*ClientsReply, error)
	Sessions(ctx context.Context, in *SessionsRequest, opts ...grpc.CallOption) (*SessionsReply, error)
	Topics(ctx context.Context, in *TopicsRequest, opts ...grpc.CallOption) (*TopicsReply, error)
}

func NewApiClient 

func NewApiClient(cc *grpc.ClientConn) ApiClient

type ApiServer 

type ApiServer interface {
	Version(context.Context, *VersionRequest) (*VersionReply, error)
	Admins(context.Context, *AdminsRequest) (*AdminsReply, error)
	Cluster(context.Context, *ClusterRequest) (*ClusterReply, error)
	Routes(context.Context, *RoutesRequest) (*RoutesReply, error)
	Status(context.Context, *StatusRequest) (*StatusReply, error)
	Broker(context.Context, *BrokerRequest) (*BrokerReply, error)
	Plugins(context.Context, *PluginsRequest) (*PluginsReply, error)
	Services(context.Context, *ServicesRequest) (*ServicesReply, error)
	Subscriptions(context.Context, *SubscriptionsRequest) (*SubscriptionsReply, error)
	Clients(context.Context, *ClientsRequest) (*ClientsReply, error)
	Sessions(context.Context, *SessionsRequest) (*SessionsReply, error)
	Topics(context.Context, *TopicsRequest) (*TopicsReply, error)
}

type ApiService 

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

func (*ApiService) Admins 

func (s *ApiService) Admins(ctx context.Context, req *AdminsRequest) (*AdminsReply, error)

func (*ApiService) Broker 

func (s *ApiService) Broker(ctx context.Context, req *BrokerRequest) (*BrokerReply, error)

Broker delegate broker command implementation in sentel

func (*ApiService) Clients 

func (s *ApiService) Clients(ctx context.Context, req *ClientsRequest) (*ClientsReply, error)

Clients delegate clients command implementation in sentel

func (*ApiService) Cluster 

func (s *ApiService) Cluster(ctx context.Context, req *ClusterRequest) (*ClusterReply, error)

func (*ApiService) Info 

func (s *ApiService) Info() *base.ServiceInfo

Name

func (*ApiService) Plugins 

func (s *ApiService) Plugins(ctx context.Context, req *PluginsRequest) (*PluginsReply, error)

func (*ApiService) Routes 

func (s *ApiService) Routes(ctx context.Context, req *RoutesRequest) (*RoutesReply, error)

Routes delegate routes command

func (*ApiService) Services 

func (s *ApiService) Services(ctx context.Context, req *ServicesRequest) (*ServicesReply, error)

Services delegate services command

func (*ApiService) Sessions 

func (s *ApiService) Sessions(ctx context.Context, req *SessionsRequest) (*SessionsReply, error)

Sessions delegate client sessions command

func (*ApiService) Start 

func (s *ApiService) Start() error

Start

func (*ApiService) Status 

func (s *ApiService) Status(ctx context.Context, req *StatusRequest) (*StatusReply, error)

func (*ApiService) Stop 

func (s *ApiService) Stop()

Stop

func (*ApiService) Subscriptions 

func (s *ApiService) Subscriptions(ctx context.Context, req *SubscriptionsRequest) (*SubscriptionsReply, error)

Subscriptions delete subscriptions command

func (*ApiService) Topics 

func (s *ApiService) Topics(ctx context.Context, req *TopicsRequest) (*TopicsReply, error)

func (*ApiService) Version 

func (s *ApiService) Version(ctx context.Context, req *VersionRequest) (*VersionReply, error)

func (*ApiService) Wait 

func (s *ApiService) Wait()

Wait

type ApiServiceFactory 

type ApiServiceFactory struct{}

ApiServiceFactory

func (*ApiServiceFactory) New 

func (m *ApiServiceFactory) New(protocol string, c core.Config, ch chan base.ServiceCommand) (base.Service, error)

New create apiService service factory

type BrokerReply 

type BrokerReply struct {
	Header  *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Stats   map[string]uint64   `` /* 131-byte string literal not displayed */
	Metrics map[string]uint64   `` /* 135-byte string literal not displayed */
}

func (*BrokerReply) Descriptor 

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

func (*BrokerReply) GetHeader 

func (m *BrokerReply) GetHeader() *ReplyMessageHeader

func (*BrokerReply) GetMetrics 

func (m *BrokerReply) GetMetrics() map[string]uint64

func (*BrokerReply) GetStats 

func (m *BrokerReply) GetStats() map[string]uint64

func (*BrokerReply) ProtoMessage 

func (*BrokerReply) ProtoMessage()

func (*BrokerReply) Reset 

func (m *BrokerReply) Reset()

func (*BrokerReply) String 

func (m *BrokerReply) String() string

type BrokerRequest 

type BrokerRequest struct {
	Category string `protobuf:"bytes,1,opt,name=Category" json:"Category,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=Service" json:"Service,omitempty"`
}

Broker

func (*BrokerRequest) Descriptor 

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

func (*BrokerRequest) GetCategory 

func (m *BrokerRequest) GetCategory() string

func (*BrokerRequest) GetService 

func (m *BrokerRequest) GetService() string

func (*BrokerRequest) ProtoMessage 

func (*BrokerRequest) ProtoMessage()

func (*BrokerRequest) Reset 

func (m *BrokerRequest) Reset()

func (*BrokerRequest) String 

func (m *BrokerRequest) String() string

type ClientInfo 

type ClientInfo struct {
	UserName     string `protobuf:"bytes,1,opt,name=UserName" json:"UserName,omitempty"`
	CleanSession bool   `protobuf:"varint,2,opt,name=CleanSession" json:"CleanSession,omitempty"`
	PeerName     string `protobuf:"bytes,3,opt,name=PeerName" json:"PeerName,omitempty"`
	ConnectTime  string `protobuf:"bytes,4,opt,name=ConnectTime" json:"ConnectTime,omitempty"`
}

func (*ClientInfo) Descriptor 

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

func (*ClientInfo) GetCleanSession 

func (m *ClientInfo) GetCleanSession() bool

func (*ClientInfo) GetConnectTime 

func (m *ClientInfo) GetConnectTime() string

func (*ClientInfo) GetPeerName 

func (m *ClientInfo) GetPeerName() string

func (*ClientInfo) GetUserName 

func (m *ClientInfo) GetUserName() string

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) Reset 

func (m *ClientInfo) Reset()

func (*ClientInfo) String 

func (m *ClientInfo) String() string

type ClientsReply 

type ClientsReply struct {
	Header  *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Clients []*ClientInfo       `protobuf:"bytes,2,rep,name=Clients" json:"Clients,omitempty"`
}

func (*ClientsReply) Descriptor 

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

func (*ClientsReply) GetClients 

func (m *ClientsReply) GetClients() []*ClientInfo

func (*ClientsReply) GetHeader 

func (m *ClientsReply) GetHeader() *ReplyMessageHeader

func (*ClientsReply) ProtoMessage 

func (*ClientsReply) ProtoMessage()

func (*ClientsReply) Reset 

func (m *ClientsReply) Reset()

func (*ClientsReply) String 

func (m *ClientsReply) String() string

type ClientsRequest 

type ClientsRequest struct {
	Category string `protobuf:"bytes,1,opt,name=Category" json:"Category,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=Service" json:"Service,omitempty"`
	ClientId string `protobuf:"bytes,3,opt,name=ClientId" json:"ClientId,omitempty"`
}

Clients

func (*ClientsRequest) Descriptor 

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

func (*ClientsRequest) GetCategory 

func (m *ClientsRequest) GetCategory() string

func (*ClientsRequest) GetClientId 

func (m *ClientsRequest) GetClientId() string

func (*ClientsRequest) GetService 

func (m *ClientsRequest) GetService() string

func (*ClientsRequest) ProtoMessage 

func (*ClientsRequest) ProtoMessage()

func (*ClientsRequest) Reset 

func (m *ClientsRequest) Reset()

func (*ClientsRequest) String 

func (m *ClientsRequest) String() string

type ClusterReply 

type ClusterReply struct {
}

func (*ClusterReply) Descriptor 

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

func (*ClusterReply) ProtoMessage 

func (*ClusterReply) ProtoMessage()

func (*ClusterReply) Reset 

func (m *ClusterReply) Reset()

func (*ClusterReply) String 

func (m *ClusterReply) String() string

type ClusterRequest 

type ClusterRequest struct {
}

func (*ClusterRequest) Descriptor 

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

func (*ClusterRequest) ProtoMessage 

func (*ClusterRequest) ProtoMessage()

func (*ClusterRequest) Reset 

func (m *ClusterRequest) Reset()

func (*ClusterRequest) String 

func (m *ClusterRequest) String() string

type PluginsReply 

type PluginsReply struct {
}

func (*PluginsReply) Descriptor 

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

func (*PluginsReply) ProtoMessage 

func (*PluginsReply) ProtoMessage()

func (*PluginsReply) Reset 

func (m *PluginsReply) Reset()

func (*PluginsReply) String 

func (m *PluginsReply) String() string

type PluginsRequest 

type PluginsRequest struct {
}

func (*PluginsRequest) Descriptor 

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

func (*PluginsRequest) ProtoMessage 

func (*PluginsRequest) ProtoMessage()

func (*PluginsRequest) Reset 

func (m *PluginsRequest) Reset()

func (*PluginsRequest) String 

func (m *PluginsRequest) String() string

type ReplyMessageHeader 

type ReplyMessageHeader struct {
	Success bool   `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=Reason" json:"Reason,omitempty"`
}

Message Header

func (*ReplyMessageHeader) Descriptor 

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

func (*ReplyMessageHeader) GetReason 

func (m *ReplyMessageHeader) GetReason() string

func (*ReplyMessageHeader) GetSuccess 

func (m *ReplyMessageHeader) GetSuccess() bool

func (*ReplyMessageHeader) ProtoMessage 

func (*ReplyMessageHeader) ProtoMessage()

func (*ReplyMessageHeader) Reset 

func (m *ReplyMessageHeader) Reset()

func (*ReplyMessageHeader) String 

func (m *ReplyMessageHeader) String() string

type RouteInfo 

type RouteInfo struct {
	Topic string   `protobuf:"bytes,1,opt,name=Topic" json:"Topic,omitempty"`
	Route []string `protobuf:"bytes,2,rep,name=Route" json:"Route,omitempty"`
}

func (*RouteInfo) Descriptor 

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

func (*RouteInfo) GetRoute 

func (m *RouteInfo) GetRoute() []string

func (*RouteInfo) GetTopic 

func (m *RouteInfo) GetTopic() string

func (*RouteInfo) ProtoMessage 

func (*RouteInfo) ProtoMessage()

func (*RouteInfo) Reset 

func (m *RouteInfo) Reset()

func (*RouteInfo) String 

func (m *RouteInfo) String() string

type RoutesReply 

type RoutesReply struct {
	Header *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Routes []*RouteInfo        `protobuf:"bytes,2,rep,name=Routes" json:"Routes,omitempty"`
}

func (*RoutesReply) Descriptor 

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

func (*RoutesReply) GetHeader 

func (m *RoutesReply) GetHeader() *ReplyMessageHeader

func (*RoutesReply) GetRoutes 

func (m *RoutesReply) GetRoutes() []*RouteInfo

func (*RoutesReply) ProtoMessage 

func (*RoutesReply) ProtoMessage()

func (*RoutesReply) Reset 

func (m *RoutesReply) Reset()

func (*RoutesReply) String 

func (m *RoutesReply) String() string

type RoutesRequest 

type RoutesRequest struct {
	Category string `protobuf:"bytes,1,opt,name=Category" json:"Category,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=Service" json:"Service,omitempty"`
	Topic    string `protobuf:"bytes,3,opt,name=Topic" json:"Topic,omitempty"`
}

Routes

func (*RoutesRequest) Descriptor 

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

func (*RoutesRequest) GetCategory 

func (m *RoutesRequest) GetCategory() string

func (*RoutesRequest) GetService 

func (m *RoutesRequest) GetService() string

func (*RoutesRequest) GetTopic 

func (m *RoutesRequest) GetTopic() string

func (*RoutesRequest) ProtoMessage 

func (*RoutesRequest) ProtoMessage()

func (*RoutesRequest) Reset 

func (m *RoutesRequest) Reset()

func (*RoutesRequest) String 

func (m *RoutesRequest) String() string

type ServiceInfo 

type ServiceInfo struct {
	ServiceName    string `protobuf:"bytes,1,opt,name=ServiceName" json:"ServiceName,omitempty"`
	Listen         string `protobuf:"bytes,2,opt,name=Listen" json:"Listen,omitempty"`
	Acceptors      uint64 `protobuf:"varint,3,opt,name=Acceptors" json:"Acceptors,omitempty"`
	MaxClients     uint64 `protobuf:"varint,4,opt,name=MaxClients" json:"MaxClients,omitempty"`
	CurrentClients uint64 `protobuf:"varint,5,opt,name=CurrentClients" json:"CurrentClients,omitempty"`
	ShutdownCount  uint64 `protobuf:"varint,6,opt,name=ShutdownCount" json:"ShutdownCount,omitempty"`
}

func (*ServiceInfo) Descriptor 

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

func (*ServiceInfo) GetAcceptors 

func (m *ServiceInfo) GetAcceptors() uint64

func (*ServiceInfo) GetCurrentClients 

func (m *ServiceInfo) GetCurrentClients() uint64

func (*ServiceInfo) GetListen 

func (m *ServiceInfo) GetListen() string

func (*ServiceInfo) GetMaxClients 

func (m *ServiceInfo) GetMaxClients() uint64

func (*ServiceInfo) GetServiceName 

func (m *ServiceInfo) GetServiceName() string

func (*ServiceInfo) GetShutdownCount 

func (m *ServiceInfo) GetShutdownCount() uint64

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset 

func (m *ServiceInfo) Reset()

func (*ServiceInfo) String 

func (m *ServiceInfo) String() string

type ServicesReply 

type ServicesReply struct {
	Header   *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Services []*ServiceInfo      `protobuf:"bytes,2,rep,name=Services" json:"Services,omitempty"`
}

func (*ServicesReply) Descriptor 

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

func (*ServicesReply) GetHeader 

func (m *ServicesReply) GetHeader() *ReplyMessageHeader

func (*ServicesReply) GetServices 

func (m *ServicesReply) GetServices() []*ServiceInfo

func (*ServicesReply) ProtoMessage 

func (*ServicesReply) ProtoMessage()

func (*ServicesReply) Reset 

func (m *ServicesReply) Reset()

func (*ServicesReply) String 

func (m *ServicesReply) String() string

type ServicesRequest 

type ServicesRequest struct {
	Category    string `protobuf:"bytes,1,opt,name=Category" json:"Category,omitempty"`
	ServiceName string `protobuf:"bytes,2,opt,name=ServiceName" json:"ServiceName,omitempty"`
	Listen      string `protobuf:"bytes,3,opt,name=Listen" json:"Listen,omitempty"`
}

Service

func (*ServicesRequest) Descriptor 

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

func (*ServicesRequest) GetCategory 

func (m *ServicesRequest) GetCategory() string

func (*ServicesRequest) GetListen 

func (m *ServicesRequest) GetListen() string

func (*ServicesRequest) GetServiceName 

func (m *ServicesRequest) GetServiceName() string

func (*ServicesRequest) ProtoMessage 

func (*ServicesRequest) ProtoMessage()

func (*ServicesRequest) Reset 

func (m *ServicesRequest) Reset()

func (*ServicesRequest) String 

func (m *ServicesRequest) String() string

type SessionInfo 

type SessionInfo struct {
	ClientId           string `protobuf:"bytes,1,opt,name=ClientId" json:"ClientId,omitempty"`
	CleanSession       bool   `protobuf:"varint,2,opt,name=CleanSession" json:"CleanSession,omitempty"`
	MessageMaxInflight uint64 `protobuf:"varint,3,opt,name=MessageMaxInflight" json:"MessageMaxInflight,omitempty"`
	MessageInflight    uint64 `protobuf:"varint,4,opt,name=MessageInflight" json:"MessageInflight,omitempty"`
	MessageInQueue     uint64 `protobuf:"varint,5,opt,name=MessageInQueue" json:"MessageInQueue,omitempty"`
	MessageDropped     uint64 `protobuf:"varint,6,opt,name=MessageDropped" json:"MessageDropped,omitempty"`
	AwaitingRel        uint64 `protobuf:"varint,7,opt,name=AwaitingRel" json:"AwaitingRel,omitempty"`
	AwaitingComp       uint64 `protobuf:"varint,8,opt,name=AwaitingComp" json:"AwaitingComp,omitempty"`
	AwaitingAck        uint64 `protobuf:"varint,9,opt,name=AwaitingAck" json:"AwaitingAck,omitempty"`
	CreatedAt          string `protobuf:"bytes,10,opt,name=CreatedAt" json:"CreatedAt,omitempty"`
}

func (*SessionInfo) Descriptor 

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

func (*SessionInfo) GetAwaitingAck 

func (m *SessionInfo) GetAwaitingAck() uint64

func (*SessionInfo) GetAwaitingComp 

func (m *SessionInfo) GetAwaitingComp() uint64

func (*SessionInfo) GetAwaitingRel 

func (m *SessionInfo) GetAwaitingRel() uint64

func (*SessionInfo) GetCleanSession 

func (m *SessionInfo) GetCleanSession() bool

func (*SessionInfo) GetClientId 

func (m *SessionInfo) GetClientId() string

func (*SessionInfo) GetCreatedAt 

func (m *SessionInfo) GetCreatedAt() string

func (*SessionInfo) GetMessageDropped 

func (m *SessionInfo) GetMessageDropped() uint64

func (*SessionInfo) GetMessageInQueue 

func (m *SessionInfo) GetMessageInQueue() uint64

func (*SessionInfo) GetMessageInflight 

func (m *SessionInfo) GetMessageInflight() uint64

func (*SessionInfo) GetMessageMaxInflight 

func (m *SessionInfo) GetMessageMaxInflight() uint64

func (*SessionInfo) ProtoMessage 

func (*SessionInfo) ProtoMessage()

func (*SessionInfo) Reset 

func (m *SessionInfo) Reset()

func (*SessionInfo) String 

func (m *SessionInfo) String() string

type SessionsReply 

type SessionsReply struct {
	Header   *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Sessions []*SessionInfo      `protobuf:"bytes,2,rep,name=Sessions" json:"Sessions,omitempty"`
}

func (*SessionsReply) Descriptor 

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

func (*SessionsReply) GetHeader 

func (m *SessionsReply) GetHeader() *ReplyMessageHeader

func (*SessionsReply) GetSessions 

func (m *SessionsReply) GetSessions() []*SessionInfo

func (*SessionsReply) ProtoMessage 

func (*SessionsReply) ProtoMessage()

func (*SessionsReply) Reset 

func (m *SessionsReply) Reset()

func (*SessionsReply) String 

func (m *SessionsReply) String() string

type SessionsRequest 

type SessionsRequest struct {
	Category   string          `protobuf:"bytes,1,opt,name=Category" json:"Category,omitempty"`
	Service    string          `protobuf:"bytes,2,opt,name=Service" json:"Service,omitempty"`
	ClientId   string          `protobuf:"bytes,3,opt,name=ClientId" json:"ClientId,omitempty"`
	Conditions map[string]bool `` /* 141-byte string literal not displayed */
}

Session

func (*SessionsRequest) Descriptor 

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

func (*SessionsRequest) GetCategory 

func (m *SessionsRequest) GetCategory() string

func (*SessionsRequest) GetClientId 

func (m *SessionsRequest) GetClientId() string

func (*SessionsRequest) GetConditions 

func (m *SessionsRequest) GetConditions() map[string]bool

func (*SessionsRequest) GetService 

func (m *SessionsRequest) GetService() string

func (*SessionsRequest) ProtoMessage 

func (*SessionsRequest) ProtoMessage()

func (*SessionsRequest) Reset 

func (m *SessionsRequest) Reset()

func (*SessionsRequest) String 

func (m *SessionsRequest) String() string

type StatusReply 

type StatusReply struct {
	Header *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
}

func (*StatusReply) Descriptor 

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

func (*StatusReply) GetHeader 

func (m *StatusReply) GetHeader() *ReplyMessageHeader

func (*StatusReply) ProtoMessage 

func (*StatusReply) ProtoMessage()

func (*StatusReply) Reset 

func (m *StatusReply) Reset()

func (*StatusReply) String 

func (m *StatusReply) String() string

type StatusRequest 

type StatusRequest struct {
}

Status

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

type SubscriptionInfo 

type SubscriptionInfo struct {
	ClientId  string `protobuf:"bytes,1,opt,name=ClientId" json:"ClientId,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=Topic" json:"Topic,omitempty"`
	Attribute string `protobuf:"bytes,3,opt,name=Attribute" json:"Attribute,omitempty"`
}

func (*SubscriptionInfo) Descriptor 

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

func (*SubscriptionInfo) GetAttribute 

func (m *SubscriptionInfo) GetAttribute() string

func (*SubscriptionInfo) GetClientId 

func (m *SubscriptionInfo) GetClientId() string

func (*SubscriptionInfo) GetTopic 

func (m *SubscriptionInfo) GetTopic() string

func (*SubscriptionInfo) ProtoMessage 

func (*SubscriptionInfo) ProtoMessage()

func (*SubscriptionInfo) Reset 

func (m *SubscriptionInfo) Reset()

func (*SubscriptionInfo) String 

func (m *SubscriptionInfo) String() string

type SubscriptionsReply 

type SubscriptionsReply struct {
	Header        *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Subscriptions []*SubscriptionInfo `protobuf:"bytes,2,rep,name=Subscriptions" json:"Subscriptions,omitempty"`
}

func (*SubscriptionsReply) Descriptor 

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

func (*SubscriptionsReply) GetHeader 

func (m *SubscriptionsReply) GetHeader() *ReplyMessageHeader

func (*SubscriptionsReply) GetSubscriptions 

func (m *SubscriptionsReply) GetSubscriptions() []*SubscriptionInfo

func (*SubscriptionsReply) ProtoMessage 

func (*SubscriptionsReply) ProtoMessage()

func (*SubscriptionsReply) Reset 

func (m *SubscriptionsReply) Reset()

func (*SubscriptionsReply) String 

func (m *SubscriptionsReply) String() string

type SubscriptionsRequest 

type SubscriptionsRequest struct {
	Service      string `protobuf:"bytes,1,opt,name=Service" json:"Service,omitempty"`
	Category     string `protobuf:"bytes,2,opt,name=Category" json:"Category,omitempty"`
	Subscription string `protobuf:"bytes,3,opt,name=Subscription" json:"Subscription,omitempty"`
}

Subscription

func (*SubscriptionsRequest) Descriptor 

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

func (*SubscriptionsRequest) GetCategory 

func (m *SubscriptionsRequest) GetCategory() string

func (*SubscriptionsRequest) GetService 

func (m *SubscriptionsRequest) GetService() string

func (*SubscriptionsRequest) GetSubscription 

func (m *SubscriptionsRequest) GetSubscription() string

func (*SubscriptionsRequest) ProtoMessage 

func (*SubscriptionsRequest) ProtoMessage()

func (*SubscriptionsRequest) Reset 

func (m *SubscriptionsRequest) Reset()

func (*SubscriptionsRequest) String 

func (m *SubscriptionsRequest) String() string

type TopicInfo 

type TopicInfo struct {
	Topic     string `protobuf:"bytes,1,opt,name=Topic" json:"Topic,omitempty"`
	Attribute string `protobuf:"bytes,2,opt,name=Attribute" json:"Attribute,omitempty"`
}

func (*TopicInfo) Descriptor 

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

func (*TopicInfo) GetAttribute 

func (m *TopicInfo) GetAttribute() string

func (*TopicInfo) GetTopic 

func (m *TopicInfo) GetTopic() string

func (*TopicInfo) ProtoMessage 

func (*TopicInfo) ProtoMessage()

func (*TopicInfo) Reset 

func (m *TopicInfo) Reset()

func (*TopicInfo) String 

func (m *TopicInfo) String() string

type TopicsReply 

type TopicsReply struct {
	Header *ReplyMessageHeader `protobuf:"bytes,1,opt,name=Header" json:"Header,omitempty"`
	Topics []*TopicInfo        `protobuf:"bytes,2,rep,name=Topics" json:"Topics,omitempty"`
}

func (*TopicsReply) Descriptor 

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

func (*TopicsReply) GetHeader 

func (m *TopicsReply) GetHeader() *ReplyMessageHeader

func (*TopicsReply) GetTopics 

func (m *TopicsReply) GetTopics() []*TopicInfo

func (*TopicsReply) ProtoMessage 

func (*TopicsReply) ProtoMessage()

func (*TopicsReply) Reset 

func (m *TopicsReply) Reset()

func (*TopicsReply) String 

func (m *TopicsReply) String() string

type TopicsRequest 

type TopicsRequest struct {
	Service  string `protobuf:"bytes,1,opt,name=Service" json:"Service,omitempty"`
	Category string `protobuf:"bytes,2,opt,name=Category" json:"Category,omitempty"`
	Topic    string `protobuf:"bytes,3,opt,name=Topic" json:"Topic,omitempty"`
}

Topic

func (*TopicsRequest) Descriptor 

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

func (*TopicsRequest) GetCategory 

func (m *TopicsRequest) GetCategory() string

func (*TopicsRequest) GetService 

func (m *TopicsRequest) GetService() string

func (*TopicsRequest) GetTopic 

func (m *TopicsRequest) GetTopic() string

func (*TopicsRequest) ProtoMessage 

func (*TopicsRequest) ProtoMessage()

func (*TopicsRequest) Reset 

func (m *TopicsRequest) Reset()

func (*TopicsRequest) String 

func (m *TopicsRequest) String() string

type VersionReply 

type VersionReply struct {
	Version string `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
}

func (*VersionReply) Descriptor 

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

func (*VersionReply) GetVersion 

func (m *VersionReply) GetVersion() string

func (*VersionReply) ProtoMessage 

func (*VersionReply) ProtoMessage()

func (*VersionReply) Reset 

func (m *VersionReply) Reset()

func (*VersionReply) String 

func (m *VersionReply) String() string

type VersionRequest 

type VersionRequest struct {
}

Version

func (*VersionRequest) Descriptor 

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

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

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.