pb

package
v0.0.0-...-0e2b5c9 Latest Latest
Warning

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

 Go to latest Published: May 7, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package pb is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var CryptoMode_name = map[int32]string{
	0: "CRYPTOMODE_UNDEFINED",
	1: "CRYPTOMODE_SYMKEY",
	2: "CRYPTOMODE_PUBKEY",
}
View Source 
var CryptoMode_value = map[string]int32{
	"CRYPTOMODE_UNDEFINED": 0,
	"CRYPTOMODE_SYMKEY":    1,
	"CRYPTOMODE_PUBKEY":    2,
}
View Source 
var EventType_name = map[int32]string{
	0: "UNDEFINED",
	1: "CLIENT_SUBSCRIBED",
	2: "CLIENT_UNSUBSCRIBED",
}
View Source 
var EventType_value = map[string]int32{
	"UNDEFINED":           0,
	"CLIENT_SUBSCRIBED":   1,
	"CLIENT_UNSUBSCRIBED": 2,
}

Functions

func RegisterC2Handler 

func RegisterC2Handler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterC2Handler registers the http handlers for service C2 to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterC2HandlerClient 

func RegisterC2HandlerClient(ctx context.Context, mux *runtime.ServeMux, client C2Client) error

RegisterC2HandlerClient registers the http handlers for service C2 to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "C2Client". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "C2Client" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "C2Client" to call the correct interceptors.

func RegisterC2HandlerFromEndpoint 

func RegisterC2HandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterC2HandlerFromEndpoint is same as RegisterC2Handler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterC2HandlerServer 

func RegisterC2HandlerServer(ctx context.Context, mux *runtime.ServeMux, server C2Server) error

RegisterC2HandlerServer registers the http handlers for service C2 to "mux". UnaryRPC :call C2Server directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterC2Server 

func RegisterC2Server(s *grpc.Server, srv C2Server)

Types

type C2Client 

type C2Client interface {
	// Create a new client
	NewClient(ctx context.Context, in *NewClientRequest, opts ...grpc.CallOption) (*NewClientResponse, error)
	// Remove a client
	RemoveClient(ctx context.Context, in *RemoveClientRequest, opts ...grpc.CallOption) (*RemoveClientResponse, error)
	// Instruct the C2 server to send a reset command to the client
	ResetClient(ctx context.Context, in *ResetClientRequest, opts ...grpc.CallOption) (*ResetClientResponse, error)
	// Generate a new key for the client
	NewClientKey(ctx context.Context, in *NewClientKeyRequest, opts ...grpc.CallOption) (*NewClientKeyResponse, error)
	// Create a new topic
	NewTopic(ctx context.Context, in *NewTopicRequest, opts ...grpc.CallOption) (*NewTopicResponse, error)
	// Remove a topic
	RemoveTopic(ctx context.Context, in *RemoveTopicRequest, opts ...grpc.CallOption) (*RemoveTopicResponse, error)
	// Associate a topic with a client
	NewTopicClient(ctx context.Context, in *NewTopicClientRequest, opts ...grpc.CallOption) (*NewTopicClientResponse, error)
	// Remove a topic / client association
	RemoveTopicClient(ctx context.Context, in *RemoveTopicClientRequest, opts ...grpc.CallOption) (*RemoveTopicClientResponse, error)
	// Count the number of topics for a client
	CountTopicsForClient(ctx context.Context, in *CountTopicsForClientRequest, opts ...grpc.CallOption) (*CountTopicsForClientResponse, error)
	// Retrieve paginated topics for a client
	GetTopicsForClient(ctx context.Context, in *GetTopicsForClientRequest, opts ...grpc.CallOption) (*GetTopicsForClientResponse, error)
	// Count the number of clients for a topic
	CountClientsForTopic(ctx context.Context, in *CountClientsForTopicRequest, opts ...grpc.CallOption) (*CountClientsForTopicResponse, error)
	// Retrieve paginated clients for a topic
	GetClientsForTopic(ctx context.Context, in *GetClientsForTopicRequest, opts ...grpc.CallOption) (*GetClientsForTopicResponse, error)
	// Count the number of clients
	CountClients(ctx context.Context, in *CountClientsRequest, opts ...grpc.CallOption) (*CountClientsResponse, error)
	// Retrieve paginated clients
	GetClients(ctx context.Context, in *GetClientsRequest, opts ...grpc.CallOption) (*GetClientsResponse, error)
	// Count the number of topics
	CountTopics(ctx context.Context, in *CountTopicsRequest, opts ...grpc.CallOption) (*CountTopicsResponse, error)
	// Retrieve paginated topics
	GetTopics(ctx context.Context, in *GetTopicsRequest, opts ...grpc.CallOption) (*GetTopicsResponse, error)
	// Create a client-client link between on a target client
	LinkClient(ctx context.Context, in *LinkClientRequest, opts ...grpc.CallOption) (*LinkClientResponse, error)
	// Remove a client-client link on a target client
	UnlinkClient(ctx context.Context, in *UnlinkClientRequest, opts ...grpc.CallOption) (*UnlinkClientResponse, error)
	// Count clients linked to the given client
	CountLinkedClients(ctx context.Context, in *CountLinkedClientsRequest, opts ...grpc.CallOption) (*CountLinkedClientsResponse, error)
	// Retrieve clients linked to the given client
	GetLinkedClients(ctx context.Context, in *GetLinkedClientsRequest, opts ...grpc.CallOption) (*GetLinkedClientsResponse, error)
	// Send a client pubkey to another client (pubkey mode only)
	SendClientPubKey(ctx context.Context, in *SendClientPubKeyRequest, opts ...grpc.CallOption) (*SendClientPubKeyResponse, error)
	// Remove a client pubkey from another client (pubkey mode only)
	RemoveClientPubKey(ctx context.Context, in *RemoveClientPubKeyRequest, opts ...grpc.CallOption) (*RemoveClientPubKeyResponse, error)
	// Remove all pubkeys from a client
	ResetClientPubKeys(ctx context.Context, in *ResetClientPubKeysRequest, opts ...grpc.CallOption) (*ResetClientPubKeysResponse, error)
	// Generate a new C2 key
	NewC2Key(ctx context.Context, in *NewC2KeyRequest, opts ...grpc.CallOption) (*NewC2KeyResponse, error)
	// ProtectMessage returns base64 encoded data, representing the input data protected with the input topic key.
	ProtectMessage(ctx context.Context, in *ProtectMessageRequest, opts ...grpc.CallOption) (*ProtectMessageResponse, error)
	// UnprotectMessage returns base64 encoded data, representing the input data unprotected with the input topic key.
	UnprotectMessage(ctx context.Context, in *UnprotectMessageRequest, opts ...grpc.CallOption) (*UnprotectMessageResponse, error)
	// Provide a stream on C2 system events, grpc only
	SubscribeToEventStream(ctx context.Context, in *SubscribeToEventStreamRequest, opts ...grpc.CallOption) (C2_SubscribeToEventStreamClient, error)
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// Returns the configured CryptoMode (symkey or pubkey) of the C2 instance
	GetCryptoMode(ctx context.Context, in *GetCryptoModeRequest, opts ...grpc.CallOption) (*GetCryptoModeResponse, error)
}

C2Client is the client API for C2 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewC2Client 

func NewC2Client(cc grpc.ClientConnInterface) C2Client

type C2Server 

type C2Server interface {
	// Create a new client
	NewClient(context.Context, *NewClientRequest) (*NewClientResponse, error)
	// Remove a client
	RemoveClient(context.Context, *RemoveClientRequest) (*RemoveClientResponse, error)
	// Instruct the C2 server to send a reset command to the client
	ResetClient(context.Context, *ResetClientRequest) (*ResetClientResponse, error)
	// Generate a new key for the client
	NewClientKey(context.Context, *NewClientKeyRequest) (*NewClientKeyResponse, error)
	// Create a new topic
	NewTopic(context.Context, *NewTopicRequest) (*NewTopicResponse, error)
	// Remove a topic
	RemoveTopic(context.Context, *RemoveTopicRequest) (*RemoveTopicResponse, error)
	// Associate a topic with a client
	NewTopicClient(context.Context, *NewTopicClientRequest) (*NewTopicClientResponse, error)
	// Remove a topic / client association
	RemoveTopicClient(context.Context, *RemoveTopicClientRequest) (*RemoveTopicClientResponse, error)
	// Count the number of topics for a client
	CountTopicsForClient(context.Context, *CountTopicsForClientRequest) (*CountTopicsForClientResponse, error)
	// Retrieve paginated topics for a client
	GetTopicsForClient(context.Context, *GetTopicsForClientRequest) (*GetTopicsForClientResponse, error)
	// Count the number of clients for a topic
	CountClientsForTopic(context.Context, *CountClientsForTopicRequest) (*CountClientsForTopicResponse, error)
	// Retrieve paginated clients for a topic
	GetClientsForTopic(context.Context, *GetClientsForTopicRequest) (*GetClientsForTopicResponse, error)
	// Count the number of clients
	CountClients(context.Context, *CountClientsRequest) (*CountClientsResponse, error)
	// Retrieve paginated clients
	GetClients(context.Context, *GetClientsRequest) (*GetClientsResponse, error)
	// Count the number of topics
	CountTopics(context.Context, *CountTopicsRequest) (*CountTopicsResponse, error)
	// Retrieve paginated topics
	GetTopics(context.Context, *GetTopicsRequest) (*GetTopicsResponse, error)
	// Create a client-client link between on a target client
	LinkClient(context.Context, *LinkClientRequest) (*LinkClientResponse, error)
	// Remove a client-client link on a target client
	UnlinkClient(context.Context, *UnlinkClientRequest) (*UnlinkClientResponse, error)
	// Count clients linked to the given client
	CountLinkedClients(context.Context, *CountLinkedClientsRequest) (*CountLinkedClientsResponse, error)
	// Retrieve clients linked to the given client
	GetLinkedClients(context.Context, *GetLinkedClientsRequest) (*GetLinkedClientsResponse, error)
	// Send a client pubkey to another client (pubkey mode only)
	SendClientPubKey(context.Context, *SendClientPubKeyRequest) (*SendClientPubKeyResponse, error)
	// Remove a client pubkey from another client (pubkey mode only)
	RemoveClientPubKey(context.Context, *RemoveClientPubKeyRequest) (*RemoveClientPubKeyResponse, error)
	// Remove all pubkeys from a client
	ResetClientPubKeys(context.Context, *ResetClientPubKeysRequest) (*ResetClientPubKeysResponse, error)
	// Generate a new C2 key
	NewC2Key(context.Context, *NewC2KeyRequest) (*NewC2KeyResponse, error)
	// ProtectMessage returns base64 encoded data, representing the input data protected with the input topic key.
	ProtectMessage(context.Context, *ProtectMessageRequest) (*ProtectMessageResponse, error)
	// UnprotectMessage returns base64 encoded data, representing the input data unprotected with the input topic key.
	UnprotectMessage(context.Context, *UnprotectMessageRequest) (*UnprotectMessageResponse, error)
	// Provide a stream on C2 system events, grpc only
	SubscribeToEventStream(*SubscribeToEventStreamRequest, C2_SubscribeToEventStreamServer) error
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// Returns the configured CryptoMode (symkey or pubkey) of the C2 instance
	GetCryptoMode(context.Context, *GetCryptoModeRequest) (*GetCryptoModeResponse, error)
}

C2Server is the server API for C2 service.

type C2_SubscribeToEventStreamClient 

type C2_SubscribeToEventStreamClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type C2_SubscribeToEventStreamServer 

type C2_SubscribeToEventStreamServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Client 

type Client struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Client) Descriptor 

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

func (*Client) GetName 

func (m *Client) GetName() string

func (*Client) ProtoMessage 

func (*Client) ProtoMessage()

func (*Client) Reset 

func (m *Client) Reset()

func (*Client) String 

func (m *Client) String() string

func (*Client) XXX_DiscardUnknown 

func (m *Client) XXX_DiscardUnknown()

func (*Client) XXX_Marshal 

func (m *Client) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Client) XXX_Merge 

func (m *Client) XXX_Merge(src proto.Message)

func (*Client) XXX_Size 

func (m *Client) XXX_Size() int

func (*Client) XXX_Unmarshal 

func (m *Client) XXX_Unmarshal(b []byte) error

type CountClientsForTopicRequest 

type CountClientsForTopicRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountClientsForTopicRequest) Descriptor 

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

func (*CountClientsForTopicRequest) GetTopic 

func (m *CountClientsForTopicRequest) GetTopic() string

func (*CountClientsForTopicRequest) ProtoMessage 

func (*CountClientsForTopicRequest) ProtoMessage()

func (*CountClientsForTopicRequest) Reset 

func (m *CountClientsForTopicRequest) Reset()

func (*CountClientsForTopicRequest) String 

func (m *CountClientsForTopicRequest) String() string

func (*CountClientsForTopicRequest) XXX_DiscardUnknown 

func (m *CountClientsForTopicRequest) XXX_DiscardUnknown()

func (*CountClientsForTopicRequest) XXX_Marshal 

func (m *CountClientsForTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountClientsForTopicRequest) XXX_Merge 

func (m *CountClientsForTopicRequest) XXX_Merge(src proto.Message)

func (*CountClientsForTopicRequest) XXX_Size 

func (m *CountClientsForTopicRequest) XXX_Size() int

func (*CountClientsForTopicRequest) XXX_Unmarshal 

func (m *CountClientsForTopicRequest) XXX_Unmarshal(b []byte) error

type CountClientsForTopicResponse 

type CountClientsForTopicResponse struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountClientsForTopicResponse) Descriptor 

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

func (*CountClientsForTopicResponse) GetCount 

func (m *CountClientsForTopicResponse) GetCount() int64

func (*CountClientsForTopicResponse) ProtoMessage 

func (*CountClientsForTopicResponse) ProtoMessage()

func (*CountClientsForTopicResponse) Reset 

func (m *CountClientsForTopicResponse) Reset()

func (*CountClientsForTopicResponse) String 

func (m *CountClientsForTopicResponse) String() string

func (*CountClientsForTopicResponse) XXX_DiscardUnknown 

func (m *CountClientsForTopicResponse) XXX_DiscardUnknown()

func (*CountClientsForTopicResponse) XXX_Marshal 

func (m *CountClientsForTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountClientsForTopicResponse) XXX_Merge 

func (m *CountClientsForTopicResponse) XXX_Merge(src proto.Message)

func (*CountClientsForTopicResponse) XXX_Size 

func (m *CountClientsForTopicResponse) XXX_Size() int

func (*CountClientsForTopicResponse) XXX_Unmarshal 

func (m *CountClientsForTopicResponse) XXX_Unmarshal(b []byte) error

type CountClientsRequest 

type CountClientsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountClientsRequest) Descriptor 

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

func (*CountClientsRequest) ProtoMessage 

func (*CountClientsRequest) ProtoMessage()

func (*CountClientsRequest) Reset 

func (m *CountClientsRequest) Reset()

func (*CountClientsRequest) String 

func (m *CountClientsRequest) String() string

func (*CountClientsRequest) XXX_DiscardUnknown 

func (m *CountClientsRequest) XXX_DiscardUnknown()

func (*CountClientsRequest) XXX_Marshal 

func (m *CountClientsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountClientsRequest) XXX_Merge 

func (m *CountClientsRequest) XXX_Merge(src proto.Message)

func (*CountClientsRequest) XXX_Size 

func (m *CountClientsRequest) XXX_Size() int

func (*CountClientsRequest) XXX_Unmarshal 

func (m *CountClientsRequest) XXX_Unmarshal(b []byte) error

type CountClientsResponse 

type CountClientsResponse struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountClientsResponse) Descriptor 

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

func (*CountClientsResponse) GetCount 

func (m *CountClientsResponse) GetCount() int64

func (*CountClientsResponse) ProtoMessage 

func (*CountClientsResponse) ProtoMessage()

func (*CountClientsResponse) Reset 

func (m *CountClientsResponse) Reset()

func (*CountClientsResponse) String 

func (m *CountClientsResponse) String() string

func (*CountClientsResponse) XXX_DiscardUnknown 

func (m *CountClientsResponse) XXX_DiscardUnknown()

func (*CountClientsResponse) XXX_Marshal 

func (m *CountClientsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountClientsResponse) XXX_Merge 

func (m *CountClientsResponse) XXX_Merge(src proto.Message)

func (*CountClientsResponse) XXX_Size 

func (m *CountClientsResponse) XXX_Size() int

func (*CountClientsResponse) XXX_Unmarshal 

func (m *CountClientsResponse) XXX_Unmarshal(b []byte) error

type CountLinkedClientsRequest 

type CountLinkedClientsRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountLinkedClientsRequest) Descriptor 

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

func (*CountLinkedClientsRequest) GetClient 

func (m *CountLinkedClientsRequest) GetClient() *Client

func (*CountLinkedClientsRequest) ProtoMessage 

func (*CountLinkedClientsRequest) ProtoMessage()

func (*CountLinkedClientsRequest) Reset 

func (m *CountLinkedClientsRequest) Reset()

func (*CountLinkedClientsRequest) String 

func (m *CountLinkedClientsRequest) String() string

func (*CountLinkedClientsRequest) XXX_DiscardUnknown 

func (m *CountLinkedClientsRequest) XXX_DiscardUnknown()

func (*CountLinkedClientsRequest) XXX_Marshal 

func (m *CountLinkedClientsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountLinkedClientsRequest) XXX_Merge 

func (m *CountLinkedClientsRequest) XXX_Merge(src proto.Message)

func (*CountLinkedClientsRequest) XXX_Size 

func (m *CountLinkedClientsRequest) XXX_Size() int

func (*CountLinkedClientsRequest) XXX_Unmarshal 

func (m *CountLinkedClientsRequest) XXX_Unmarshal(b []byte) error

type CountLinkedClientsResponse 

type CountLinkedClientsResponse struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountLinkedClientsResponse) Descriptor 

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

func (*CountLinkedClientsResponse) GetCount 

func (m *CountLinkedClientsResponse) GetCount() int64

func (*CountLinkedClientsResponse) ProtoMessage 

func (*CountLinkedClientsResponse) ProtoMessage()

func (*CountLinkedClientsResponse) Reset 

func (m *CountLinkedClientsResponse) Reset()

func (*CountLinkedClientsResponse) String 

func (m *CountLinkedClientsResponse) String() string

func (*CountLinkedClientsResponse) XXX_DiscardUnknown 

func (m *CountLinkedClientsResponse) XXX_DiscardUnknown()

func (*CountLinkedClientsResponse) XXX_Marshal 

func (m *CountLinkedClientsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountLinkedClientsResponse) XXX_Merge 

func (m *CountLinkedClientsResponse) XXX_Merge(src proto.Message)

func (*CountLinkedClientsResponse) XXX_Size 

func (m *CountLinkedClientsResponse) XXX_Size() int

func (*CountLinkedClientsResponse) XXX_Unmarshal 

func (m *CountLinkedClientsResponse) XXX_Unmarshal(b []byte) error

type CountTopicsForClientRequest 

type CountTopicsForClientRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountTopicsForClientRequest) Descriptor 

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

func (*CountTopicsForClientRequest) GetClient 

func (m *CountTopicsForClientRequest) GetClient() *Client

func (*CountTopicsForClientRequest) ProtoMessage 

func (*CountTopicsForClientRequest) ProtoMessage()

func (*CountTopicsForClientRequest) Reset 

func (m *CountTopicsForClientRequest) Reset()

func (*CountTopicsForClientRequest) String 

func (m *CountTopicsForClientRequest) String() string

func (*CountTopicsForClientRequest) XXX_DiscardUnknown 

func (m *CountTopicsForClientRequest) XXX_DiscardUnknown()

func (*CountTopicsForClientRequest) XXX_Marshal 

func (m *CountTopicsForClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountTopicsForClientRequest) XXX_Merge 

func (m *CountTopicsForClientRequest) XXX_Merge(src proto.Message)

func (*CountTopicsForClientRequest) XXX_Size 

func (m *CountTopicsForClientRequest) XXX_Size() int

func (*CountTopicsForClientRequest) XXX_Unmarshal 

func (m *CountTopicsForClientRequest) XXX_Unmarshal(b []byte) error

type CountTopicsForClientResponse 

type CountTopicsForClientResponse struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountTopicsForClientResponse) Descriptor 

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

func (*CountTopicsForClientResponse) GetCount 

func (m *CountTopicsForClientResponse) GetCount() int64

func (*CountTopicsForClientResponse) ProtoMessage 

func (*CountTopicsForClientResponse) ProtoMessage()

func (*CountTopicsForClientResponse) Reset 

func (m *CountTopicsForClientResponse) Reset()

func (*CountTopicsForClientResponse) String 

func (m *CountTopicsForClientResponse) String() string

func (*CountTopicsForClientResponse) XXX_DiscardUnknown 

func (m *CountTopicsForClientResponse) XXX_DiscardUnknown()

func (*CountTopicsForClientResponse) XXX_Marshal 

func (m *CountTopicsForClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountTopicsForClientResponse) XXX_Merge 

func (m *CountTopicsForClientResponse) XXX_Merge(src proto.Message)

func (*CountTopicsForClientResponse) XXX_Size 

func (m *CountTopicsForClientResponse) XXX_Size() int

func (*CountTopicsForClientResponse) XXX_Unmarshal 

func (m *CountTopicsForClientResponse) XXX_Unmarshal(b []byte) error

type CountTopicsRequest 

type CountTopicsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountTopicsRequest) Descriptor 

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

func (*CountTopicsRequest) ProtoMessage 

func (*CountTopicsRequest) ProtoMessage()

func (*CountTopicsRequest) Reset 

func (m *CountTopicsRequest) Reset()

func (*CountTopicsRequest) String 

func (m *CountTopicsRequest) String() string

func (*CountTopicsRequest) XXX_DiscardUnknown 

func (m *CountTopicsRequest) XXX_DiscardUnknown()

func (*CountTopicsRequest) XXX_Marshal 

func (m *CountTopicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountTopicsRequest) XXX_Merge 

func (m *CountTopicsRequest) XXX_Merge(src proto.Message)

func (*CountTopicsRequest) XXX_Size 

func (m *CountTopicsRequest) XXX_Size() int

func (*CountTopicsRequest) XXX_Unmarshal 

func (m *CountTopicsRequest) XXX_Unmarshal(b []byte) error

type CountTopicsResponse 

type CountTopicsResponse struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountTopicsResponse) Descriptor 

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

func (*CountTopicsResponse) GetCount 

func (m *CountTopicsResponse) GetCount() int64

func (*CountTopicsResponse) ProtoMessage 

func (*CountTopicsResponse) ProtoMessage()

func (*CountTopicsResponse) Reset 

func (m *CountTopicsResponse) Reset()

func (*CountTopicsResponse) String 

func (m *CountTopicsResponse) String() string

func (*CountTopicsResponse) XXX_DiscardUnknown 

func (m *CountTopicsResponse) XXX_DiscardUnknown()

func (*CountTopicsResponse) XXX_Marshal 

func (m *CountTopicsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountTopicsResponse) XXX_Merge 

func (m *CountTopicsResponse) XXX_Merge(src proto.Message)

func (*CountTopicsResponse) XXX_Size 

func (m *CountTopicsResponse) XXX_Size() int

func (*CountTopicsResponse) XXX_Unmarshal 

func (m *CountTopicsResponse) XXX_Unmarshal(b []byte) error

type CryptoMode 

type CryptoMode int32
const (
	CryptoMode_CRYPTOMODE_UNDEFINED CryptoMode = 0
	CryptoMode_CRYPTOMODE_SYMKEY    CryptoMode = 1
	CryptoMode_CRYPTOMODE_PUBKEY    CryptoMode = 2
)

func (CryptoMode) EnumDescriptor 

func (CryptoMode) EnumDescriptor() ([]byte, []int)

func (CryptoMode) String 

func (x CryptoMode) String() string

type Event 

type Event struct {
	Type   EventType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.EventType" json:"type,omitempty"`
	Source string    `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Target string    `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// Hold the time where event is sent
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetSource 

func (m *Event) GetSource() string

func (*Event) GetTarget 

func (m *Event) GetTarget() string

func (*Event) GetTimestamp 

func (m *Event) GetTimestamp() *timestamp.Timestamp

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventType 

type EventType int32
const (
	EventType_UNDEFINED           EventType = 0
	EventType_CLIENT_SUBSCRIBED   EventType = 1
	EventType_CLIENT_UNSUBSCRIBED EventType = 2
)

func (EventType) EnumDescriptor 

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String 

func (x EventType) String() string

type GetClientsForTopicRequest 

type GetClientsForTopicRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Offset               int64    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Count                int64    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClientsForTopicRequest) Descriptor 

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

func (*GetClientsForTopicRequest) GetCount 

func (m *GetClientsForTopicRequest) GetCount() int64

func (*GetClientsForTopicRequest) GetOffset 

func (m *GetClientsForTopicRequest) GetOffset() int64

func (*GetClientsForTopicRequest) GetTopic 

func (m *GetClientsForTopicRequest) GetTopic() string

func (*GetClientsForTopicRequest) ProtoMessage 

func (*GetClientsForTopicRequest) ProtoMessage()

func (*GetClientsForTopicRequest) Reset 

func (m *GetClientsForTopicRequest) Reset()

func (*GetClientsForTopicRequest) String 

func (m *GetClientsForTopicRequest) String() string

func (*GetClientsForTopicRequest) XXX_DiscardUnknown 

func (m *GetClientsForTopicRequest) XXX_DiscardUnknown()

func (*GetClientsForTopicRequest) XXX_Marshal 

func (m *GetClientsForTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClientsForTopicRequest) XXX_Merge 

func (m *GetClientsForTopicRequest) XXX_Merge(src proto.Message)

func (*GetClientsForTopicRequest) XXX_Size 

func (m *GetClientsForTopicRequest) XXX_Size() int

func (*GetClientsForTopicRequest) XXX_Unmarshal 

func (m *GetClientsForTopicRequest) XXX_Unmarshal(b []byte) error

type GetClientsForTopicResponse 

type GetClientsForTopicResponse struct {
	Clients              []*Client `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetClientsForTopicResponse) Descriptor 

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

func (*GetClientsForTopicResponse) GetClients 

func (m *GetClientsForTopicResponse) GetClients() []*Client

func (*GetClientsForTopicResponse) ProtoMessage 

func (*GetClientsForTopicResponse) ProtoMessage()

func (*GetClientsForTopicResponse) Reset 

func (m *GetClientsForTopicResponse) Reset()

func (*GetClientsForTopicResponse) String 

func (m *GetClientsForTopicResponse) String() string

func (*GetClientsForTopicResponse) XXX_DiscardUnknown 

func (m *GetClientsForTopicResponse) XXX_DiscardUnknown()

func (*GetClientsForTopicResponse) XXX_Marshal 

func (m *GetClientsForTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClientsForTopicResponse) XXX_Merge 

func (m *GetClientsForTopicResponse) XXX_Merge(src proto.Message)

func (*GetClientsForTopicResponse) XXX_Size 

func (m *GetClientsForTopicResponse) XXX_Size() int

func (*GetClientsForTopicResponse) XXX_Unmarshal 

func (m *GetClientsForTopicResponse) XXX_Unmarshal(b []byte) error

type GetClientsRequest 

type GetClientsRequest struct {
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Count                int64    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClientsRequest) Descriptor 

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

func (*GetClientsRequest) GetCount 

func (m *GetClientsRequest) GetCount() int64

func (*GetClientsRequest) GetOffset 

func (m *GetClientsRequest) GetOffset() int64

func (*GetClientsRequest) ProtoMessage 

func (*GetClientsRequest) ProtoMessage()

func (*GetClientsRequest) Reset 

func (m *GetClientsRequest) Reset()

func (*GetClientsRequest) String 

func (m *GetClientsRequest) String() string

func (*GetClientsRequest) XXX_DiscardUnknown 

func (m *GetClientsRequest) XXX_DiscardUnknown()

func (*GetClientsRequest) XXX_Marshal 

func (m *GetClientsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClientsRequest) XXX_Merge 

func (m *GetClientsRequest) XXX_Merge(src proto.Message)

func (*GetClientsRequest) XXX_Size 

func (m *GetClientsRequest) XXX_Size() int

func (*GetClientsRequest) XXX_Unmarshal 

func (m *GetClientsRequest) XXX_Unmarshal(b []byte) error

type GetClientsResponse 

type GetClientsResponse struct {
	Clients              []*Client `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetClientsResponse) Descriptor 

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

func (*GetClientsResponse) GetClients 

func (m *GetClientsResponse) GetClients() []*Client

func (*GetClientsResponse) ProtoMessage 

func (*GetClientsResponse) ProtoMessage()

func (*GetClientsResponse) Reset 

func (m *GetClientsResponse) Reset()

func (*GetClientsResponse) String 

func (m *GetClientsResponse) String() string

func (*GetClientsResponse) XXX_DiscardUnknown 

func (m *GetClientsResponse) XXX_DiscardUnknown()

func (*GetClientsResponse) XXX_Marshal 

func (m *GetClientsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClientsResponse) XXX_Merge 

func (m *GetClientsResponse) XXX_Merge(src proto.Message)

func (*GetClientsResponse) XXX_Size 

func (m *GetClientsResponse) XXX_Size() int

func (*GetClientsResponse) XXX_Unmarshal 

func (m *GetClientsResponse) XXX_Unmarshal(b []byte) error

type GetCryptoModeRequest 

type GetCryptoModeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCryptoModeRequest) Descriptor 

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

func (*GetCryptoModeRequest) ProtoMessage 

func (*GetCryptoModeRequest) ProtoMessage()

func (*GetCryptoModeRequest) Reset 

func (m *GetCryptoModeRequest) Reset()

func (*GetCryptoModeRequest) String 

func (m *GetCryptoModeRequest) String() string

func (*GetCryptoModeRequest) XXX_DiscardUnknown 

func (m *GetCryptoModeRequest) XXX_DiscardUnknown()

func (*GetCryptoModeRequest) XXX_Marshal 

func (m *GetCryptoModeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCryptoModeRequest) XXX_Merge 

func (m *GetCryptoModeRequest) XXX_Merge(src proto.Message)

func (*GetCryptoModeRequest) XXX_Size 

func (m *GetCryptoModeRequest) XXX_Size() int

func (*GetCryptoModeRequest) XXX_Unmarshal 

func (m *GetCryptoModeRequest) XXX_Unmarshal(b []byte) error

type GetCryptoModeResponse 

type GetCryptoModeResponse struct {
	CryptoMode           CryptoMode `protobuf:"varint,1,opt,name=CryptoMode,proto3,enum=pb.CryptoMode" json:"CryptoMode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetCryptoModeResponse) Descriptor 

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

func (*GetCryptoModeResponse) GetCryptoMode 

func (m *GetCryptoModeResponse) GetCryptoMode() CryptoMode

func (*GetCryptoModeResponse) ProtoMessage 

func (*GetCryptoModeResponse) ProtoMessage()

func (*GetCryptoModeResponse) Reset 

func (m *GetCryptoModeResponse) Reset()

func (*GetCryptoModeResponse) String 

func (m *GetCryptoModeResponse) String() string

func (*GetCryptoModeResponse) XXX_DiscardUnknown 

func (m *GetCryptoModeResponse) XXX_DiscardUnknown()

func (*GetCryptoModeResponse) XXX_Marshal 

func (m *GetCryptoModeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCryptoModeResponse) XXX_Merge 

func (m *GetCryptoModeResponse) XXX_Merge(src proto.Message)

func (*GetCryptoModeResponse) XXX_Size 

func (m *GetCryptoModeResponse) XXX_Size() int

func (*GetCryptoModeResponse) XXX_Unmarshal 

func (m *GetCryptoModeResponse) XXX_Unmarshal(b []byte) error

type GetLinkedClientsRequest 

type GetLinkedClientsRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Offset               int64    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Count                int64    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetLinkedClientsRequest) Descriptor 

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

func (*GetLinkedClientsRequest) GetClient 

func (m *GetLinkedClientsRequest) GetClient() *Client

func (*GetLinkedClientsRequest) GetCount 

func (m *GetLinkedClientsRequest) GetCount() int64

func (*GetLinkedClientsRequest) GetOffset 

func (m *GetLinkedClientsRequest) GetOffset() int64

func (*GetLinkedClientsRequest) ProtoMessage 

func (*GetLinkedClientsRequest) ProtoMessage()

func (*GetLinkedClientsRequest) Reset 

func (m *GetLinkedClientsRequest) Reset()

func (*GetLinkedClientsRequest) String 

func (m *GetLinkedClientsRequest) String() string

func (*GetLinkedClientsRequest) XXX_DiscardUnknown 

func (m *GetLinkedClientsRequest) XXX_DiscardUnknown()

func (*GetLinkedClientsRequest) XXX_Marshal 

func (m *GetLinkedClientsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLinkedClientsRequest) XXX_Merge 

func (m *GetLinkedClientsRequest) XXX_Merge(src proto.Message)

func (*GetLinkedClientsRequest) XXX_Size 

func (m *GetLinkedClientsRequest) XXX_Size() int

func (*GetLinkedClientsRequest) XXX_Unmarshal 

func (m *GetLinkedClientsRequest) XXX_Unmarshal(b []byte) error

type GetLinkedClientsResponse 

type GetLinkedClientsResponse struct {
	Clients              []*Client `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetLinkedClientsResponse) Descriptor 

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

func (*GetLinkedClientsResponse) GetClients 

func (m *GetLinkedClientsResponse) GetClients() []*Client

func (*GetLinkedClientsResponse) ProtoMessage 

func (*GetLinkedClientsResponse) ProtoMessage()

func (*GetLinkedClientsResponse) Reset 

func (m *GetLinkedClientsResponse) Reset()

func (*GetLinkedClientsResponse) String 

func (m *GetLinkedClientsResponse) String() string

func (*GetLinkedClientsResponse) XXX_DiscardUnknown 

func (m *GetLinkedClientsResponse) XXX_DiscardUnknown()

func (*GetLinkedClientsResponse) XXX_Marshal 

func (m *GetLinkedClientsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLinkedClientsResponse) XXX_Merge 

func (m *GetLinkedClientsResponse) XXX_Merge(src proto.Message)

func (*GetLinkedClientsResponse) XXX_Size 

func (m *GetLinkedClientsResponse) XXX_Size() int

func (*GetLinkedClientsResponse) XXX_Unmarshal 

func (m *GetLinkedClientsResponse) XXX_Unmarshal(b []byte) error

type GetTopicsForClientRequest 

type GetTopicsForClientRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Offset               int64    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Count                int64    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTopicsForClientRequest) Descriptor 

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

func (*GetTopicsForClientRequest) GetClient 

func (m *GetTopicsForClientRequest) GetClient() *Client

func (*GetTopicsForClientRequest) GetCount 

func (m *GetTopicsForClientRequest) GetCount() int64

func (*GetTopicsForClientRequest) GetOffset 

func (m *GetTopicsForClientRequest) GetOffset() int64

func (*GetTopicsForClientRequest) ProtoMessage 

func (*GetTopicsForClientRequest) ProtoMessage()

func (*GetTopicsForClientRequest) Reset 

func (m *GetTopicsForClientRequest) Reset()

func (*GetTopicsForClientRequest) String 

func (m *GetTopicsForClientRequest) String() string

func (*GetTopicsForClientRequest) XXX_DiscardUnknown 

func (m *GetTopicsForClientRequest) XXX_DiscardUnknown()

func (*GetTopicsForClientRequest) XXX_Marshal 

func (m *GetTopicsForClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTopicsForClientRequest) XXX_Merge 

func (m *GetTopicsForClientRequest) XXX_Merge(src proto.Message)

func (*GetTopicsForClientRequest) XXX_Size 

func (m *GetTopicsForClientRequest) XXX_Size() int

func (*GetTopicsForClientRequest) XXX_Unmarshal 

func (m *GetTopicsForClientRequest) XXX_Unmarshal(b []byte) error

type GetTopicsForClientResponse 

type GetTopicsForClientResponse struct {
	Topics               []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTopicsForClientResponse) Descriptor 

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

func (*GetTopicsForClientResponse) GetTopics 

func (m *GetTopicsForClientResponse) GetTopics() []string

func (*GetTopicsForClientResponse) ProtoMessage 

func (*GetTopicsForClientResponse) ProtoMessage()

func (*GetTopicsForClientResponse) Reset 

func (m *GetTopicsForClientResponse) Reset()

func (*GetTopicsForClientResponse) String 

func (m *GetTopicsForClientResponse) String() string

func (*GetTopicsForClientResponse) XXX_DiscardUnknown 

func (m *GetTopicsForClientResponse) XXX_DiscardUnknown()

func (*GetTopicsForClientResponse) XXX_Marshal 

func (m *GetTopicsForClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTopicsForClientResponse) XXX_Merge 

func (m *GetTopicsForClientResponse) XXX_Merge(src proto.Message)

func (*GetTopicsForClientResponse) XXX_Size 

func (m *GetTopicsForClientResponse) XXX_Size() int

func (*GetTopicsForClientResponse) XXX_Unmarshal 

func (m *GetTopicsForClientResponse) XXX_Unmarshal(b []byte) error

type GetTopicsRequest 

type GetTopicsRequest struct {
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Count                int64    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTopicsRequest) Descriptor 

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

func (*GetTopicsRequest) GetCount 

func (m *GetTopicsRequest) GetCount() int64

func (*GetTopicsRequest) GetOffset 

func (m *GetTopicsRequest) GetOffset() int64

func (*GetTopicsRequest) ProtoMessage 

func (*GetTopicsRequest) ProtoMessage()

func (*GetTopicsRequest) Reset 

func (m *GetTopicsRequest) Reset()

func (*GetTopicsRequest) String 

func (m *GetTopicsRequest) String() string

func (*GetTopicsRequest) XXX_DiscardUnknown 

func (m *GetTopicsRequest) XXX_DiscardUnknown()

func (*GetTopicsRequest) XXX_Marshal 

func (m *GetTopicsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTopicsRequest) XXX_Merge 

func (m *GetTopicsRequest) XXX_Merge(src proto.Message)

func (*GetTopicsRequest) XXX_Size 

func (m *GetTopicsRequest) XXX_Size() int

func (*GetTopicsRequest) XXX_Unmarshal 

func (m *GetTopicsRequest) XXX_Unmarshal(b []byte) error

type GetTopicsResponse 

type GetTopicsResponse struct {
	Topics               []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTopicsResponse) Descriptor 

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

func (*GetTopicsResponse) GetTopics 

func (m *GetTopicsResponse) GetTopics() []string

func (*GetTopicsResponse) ProtoMessage 

func (*GetTopicsResponse) ProtoMessage()

func (*GetTopicsResponse) Reset 

func (m *GetTopicsResponse) Reset()

func (*GetTopicsResponse) String 

func (m *GetTopicsResponse) String() string

func (*GetTopicsResponse) XXX_DiscardUnknown 

func (m *GetTopicsResponse) XXX_DiscardUnknown()

func (*GetTopicsResponse) XXX_Marshal 

func (m *GetTopicsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTopicsResponse) XXX_Merge 

func (m *GetTopicsResponse) XXX_Merge(src proto.Message)

func (*GetTopicsResponse) XXX_Size 

func (m *GetTopicsResponse) XXX_Size() int

func (*GetTopicsResponse) XXX_Unmarshal 

func (m *GetTopicsResponse) XXX_Unmarshal(b []byte) error

type HealthCheckRequest 

type HealthCheckRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckRequest) Descriptor 

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

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) XXX_DiscardUnknown 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal 

func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckRequest) XXX_Merge 

func (m *HealthCheckRequest) XXX_Merge(src proto.Message)

func (*HealthCheckRequest) XXX_Size 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal 

func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error

type HealthCheckResponse 

type HealthCheckResponse struct {
	Code                 int64    `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Status               string   `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) GetCode 

func (m *HealthCheckResponse) GetCode() int64

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() string

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckResponse) XXX_Merge 

func (m *HealthCheckResponse) XXX_Merge(src proto.Message)

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error

type LinkClientRequest 

type LinkClientRequest struct {
	SourceClient         *Client  `protobuf:"bytes,1,opt,name=sourceClient,proto3" json:"sourceClient,omitempty"`
	TargetClient         *Client  `protobuf:"bytes,2,opt,name=targetClient,proto3" json:"targetClient,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LinkClientRequest) Descriptor 

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

func (*LinkClientRequest) GetSourceClient 

func (m *LinkClientRequest) GetSourceClient() *Client

func (*LinkClientRequest) GetTargetClient 

func (m *LinkClientRequest) GetTargetClient() *Client

func (*LinkClientRequest) ProtoMessage 

func (*LinkClientRequest) ProtoMessage()

func (*LinkClientRequest) Reset 

func (m *LinkClientRequest) Reset()

func (*LinkClientRequest) String 

func (m *LinkClientRequest) String() string

func (*LinkClientRequest) XXX_DiscardUnknown 

func (m *LinkClientRequest) XXX_DiscardUnknown()

func (*LinkClientRequest) XXX_Marshal 

func (m *LinkClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LinkClientRequest) XXX_Merge 

func (m *LinkClientRequest) XXX_Merge(src proto.Message)

func (*LinkClientRequest) XXX_Size 

func (m *LinkClientRequest) XXX_Size() int

func (*LinkClientRequest) XXX_Unmarshal 

func (m *LinkClientRequest) XXX_Unmarshal(b []byte) error

type LinkClientResponse 

type LinkClientResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LinkClientResponse) Descriptor 

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

func (*LinkClientResponse) ProtoMessage 

func (*LinkClientResponse) ProtoMessage()

func (*LinkClientResponse) Reset 

func (m *LinkClientResponse) Reset()

func (*LinkClientResponse) String 

func (m *LinkClientResponse) String() string

func (*LinkClientResponse) XXX_DiscardUnknown 

func (m *LinkClientResponse) XXX_DiscardUnknown()

func (*LinkClientResponse) XXX_Marshal 

func (m *LinkClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LinkClientResponse) XXX_Merge 

func (m *LinkClientResponse) XXX_Merge(src proto.Message)

func (*LinkClientResponse) XXX_Size 

func (m *LinkClientResponse) XXX_Size() int

func (*LinkClientResponse) XXX_Unmarshal 

func (m *LinkClientResponse) XXX_Unmarshal(b []byte) error

type MockC2_SubscribeToEventStreamClient 

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

MockC2_SubscribeToEventStreamClient is a mock of C2_SubscribeToEventStreamClient interface

func NewMockC2_SubscribeToEventStreamClient 

func NewMockC2_SubscribeToEventStreamClient(ctrl *gomock.Controller) *MockC2_SubscribeToEventStreamClient

NewMockC2_SubscribeToEventStreamClient creates a new mock instance

func (*MockC2_SubscribeToEventStreamClient) CloseSend 

func (m *MockC2_SubscribeToEventStreamClient) CloseSend() error

CloseSend mocks base method

func (*MockC2_SubscribeToEventStreamClient) Context 

func (m *MockC2_SubscribeToEventStreamClient) Context() context.Context

Context mocks base method

func (*MockC2_SubscribeToEventStreamClient) EXPECT 

func (m *MockC2_SubscribeToEventStreamClient) EXPECT() *MockC2_SubscribeToEventStreamClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockC2_SubscribeToEventStreamClient) Header 

func (m *MockC2_SubscribeToEventStreamClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockC2_SubscribeToEventStreamClient) Recv 

func (m *MockC2_SubscribeToEventStreamClient) Recv() (*Event, error)

Recv mocks base method

func (*MockC2_SubscribeToEventStreamClient) RecvMsg 

func (m *MockC2_SubscribeToEventStreamClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method

func (*MockC2_SubscribeToEventStreamClient) SendMsg 

func (m *MockC2_SubscribeToEventStreamClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method

func (*MockC2_SubscribeToEventStreamClient) Trailer 

func (m *MockC2_SubscribeToEventStreamClient) Trailer() metadata.MD

Trailer mocks base method

type MockC2_SubscribeToEventStreamClientMockRecorder 

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

MockC2_SubscribeToEventStreamClientMockRecorder is the mock recorder for MockC2_SubscribeToEventStreamClient

func (*MockC2_SubscribeToEventStreamClientMockRecorder) CloseSend 

func (mr *MockC2_SubscribeToEventStreamClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockC2_SubscribeToEventStreamClientMockRecorder) Context 

func (mr *MockC2_SubscribeToEventStreamClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockC2_SubscribeToEventStreamClientMockRecorder) Header 

func (mr *MockC2_SubscribeToEventStreamClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockC2_SubscribeToEventStreamClientMockRecorder) Recv 

func (mr *MockC2_SubscribeToEventStreamClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockC2_SubscribeToEventStreamClientMockRecorder) RecvMsg 

func (mr *MockC2_SubscribeToEventStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockC2_SubscribeToEventStreamClientMockRecorder) SendMsg 

func (mr *MockC2_SubscribeToEventStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockC2_SubscribeToEventStreamClientMockRecorder) Trailer 

func (mr *MockC2_SubscribeToEventStreamClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type NewC2KeyRequest 

type NewC2KeyRequest struct {
	Force                bool     `protobuf:"varint,1,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewC2KeyRequest) Descriptor 

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

func (*NewC2KeyRequest) GetForce 

func (m *NewC2KeyRequest) GetForce() bool

func (*NewC2KeyRequest) ProtoMessage 

func (*NewC2KeyRequest) ProtoMessage()

func (*NewC2KeyRequest) Reset 

func (m *NewC2KeyRequest) Reset()

func (*NewC2KeyRequest) String 

func (m *NewC2KeyRequest) String() string

func (*NewC2KeyRequest) XXX_DiscardUnknown 

func (m *NewC2KeyRequest) XXX_DiscardUnknown()

func (*NewC2KeyRequest) XXX_Marshal 

func (m *NewC2KeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewC2KeyRequest) XXX_Merge 

func (m *NewC2KeyRequest) XXX_Merge(src proto.Message)

func (*NewC2KeyRequest) XXX_Size 

func (m *NewC2KeyRequest) XXX_Size() int

func (*NewC2KeyRequest) XXX_Unmarshal 

func (m *NewC2KeyRequest) XXX_Unmarshal(b []byte) error

type NewC2KeyResponse 

type NewC2KeyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewC2KeyResponse) Descriptor 

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

func (*NewC2KeyResponse) ProtoMessage 

func (*NewC2KeyResponse) ProtoMessage()

func (*NewC2KeyResponse) Reset 

func (m *NewC2KeyResponse) Reset()

func (*NewC2KeyResponse) String 

func (m *NewC2KeyResponse) String() string

func (*NewC2KeyResponse) XXX_DiscardUnknown 

func (m *NewC2KeyResponse) XXX_DiscardUnknown()

func (*NewC2KeyResponse) XXX_Marshal 

func (m *NewC2KeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewC2KeyResponse) XXX_Merge 

func (m *NewC2KeyResponse) XXX_Merge(src proto.Message)

func (*NewC2KeyResponse) XXX_Size 

func (m *NewC2KeyResponse) XXX_Size() int

func (*NewC2KeyResponse) XXX_Unmarshal 

func (m *NewC2KeyResponse) XXX_Unmarshal(b []byte) error

type NewClientKeyRequest 

type NewClientKeyRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewClientKeyRequest) Descriptor 

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

func (*NewClientKeyRequest) GetClient 

func (m *NewClientKeyRequest) GetClient() *Client

func (*NewClientKeyRequest) ProtoMessage 

func (*NewClientKeyRequest) ProtoMessage()

func (*NewClientKeyRequest) Reset 

func (m *NewClientKeyRequest) Reset()

func (*NewClientKeyRequest) String 

func (m *NewClientKeyRequest) String() string

func (*NewClientKeyRequest) XXX_DiscardUnknown 

func (m *NewClientKeyRequest) XXX_DiscardUnknown()

func (*NewClientKeyRequest) XXX_Marshal 

func (m *NewClientKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewClientKeyRequest) XXX_Merge 

func (m *NewClientKeyRequest) XXX_Merge(src proto.Message)

func (*NewClientKeyRequest) XXX_Size 

func (m *NewClientKeyRequest) XXX_Size() int

func (*NewClientKeyRequest) XXX_Unmarshal 

func (m *NewClientKeyRequest) XXX_Unmarshal(b []byte) error

type NewClientKeyResponse 

type NewClientKeyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewClientKeyResponse) Descriptor 

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

func (*NewClientKeyResponse) ProtoMessage 

func (*NewClientKeyResponse) ProtoMessage()

func (*NewClientKeyResponse) Reset 

func (m *NewClientKeyResponse) Reset()

func (*NewClientKeyResponse) String 

func (m *NewClientKeyResponse) String() string

func (*NewClientKeyResponse) XXX_DiscardUnknown 

func (m *NewClientKeyResponse) XXX_DiscardUnknown()

func (*NewClientKeyResponse) XXX_Marshal 

func (m *NewClientKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewClientKeyResponse) XXX_Merge 

func (m *NewClientKeyResponse) XXX_Merge(src proto.Message)

func (*NewClientKeyResponse) XXX_Size 

func (m *NewClientKeyResponse) XXX_Size() int

func (*NewClientKeyResponse) XXX_Unmarshal 

func (m *NewClientKeyResponse) XXX_Unmarshal(b []byte) error

type NewClientRequest 

type NewClientRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewClientRequest) Descriptor 

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

func (*NewClientRequest) GetClient 

func (m *NewClientRequest) GetClient() *Client

func (*NewClientRequest) GetKey 

func (m *NewClientRequest) GetKey() []byte

func (*NewClientRequest) ProtoMessage 

func (*NewClientRequest) ProtoMessage()

func (*NewClientRequest) Reset 

func (m *NewClientRequest) Reset()

func (*NewClientRequest) String 

func (m *NewClientRequest) String() string

func (*NewClientRequest) XXX_DiscardUnknown 

func (m *NewClientRequest) XXX_DiscardUnknown()

func (*NewClientRequest) XXX_Marshal 

func (m *NewClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewClientRequest) XXX_Merge 

func (m *NewClientRequest) XXX_Merge(src proto.Message)

func (*NewClientRequest) XXX_Size 

func (m *NewClientRequest) XXX_Size() int

func (*NewClientRequest) XXX_Unmarshal 

func (m *NewClientRequest) XXX_Unmarshal(b []byte) error

type NewClientResponse 

type NewClientResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewClientResponse) Descriptor 

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

func (*NewClientResponse) ProtoMessage 

func (*NewClientResponse) ProtoMessage()

func (*NewClientResponse) Reset 

func (m *NewClientResponse) Reset()

func (*NewClientResponse) String 

func (m *NewClientResponse) String() string

func (*NewClientResponse) XXX_DiscardUnknown 

func (m *NewClientResponse) XXX_DiscardUnknown()

func (*NewClientResponse) XXX_Marshal 

func (m *NewClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewClientResponse) XXX_Merge 

func (m *NewClientResponse) XXX_Merge(src proto.Message)

func (*NewClientResponse) XXX_Size 

func (m *NewClientResponse) XXX_Size() int

func (*NewClientResponse) XXX_Unmarshal 

func (m *NewClientResponse) XXX_Unmarshal(b []byte) error

type NewTopicClientRequest 

type NewTopicClientRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Topic                string   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewTopicClientRequest) Descriptor 

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

func (*NewTopicClientRequest) GetClient 

func (m *NewTopicClientRequest) GetClient() *Client

func (*NewTopicClientRequest) GetTopic 

func (m *NewTopicClientRequest) GetTopic() string

func (*NewTopicClientRequest) ProtoMessage 

func (*NewTopicClientRequest) ProtoMessage()

func (*NewTopicClientRequest) Reset 

func (m *NewTopicClientRequest) Reset()

func (*NewTopicClientRequest) String 

func (m *NewTopicClientRequest) String() string

func (*NewTopicClientRequest) XXX_DiscardUnknown 

func (m *NewTopicClientRequest) XXX_DiscardUnknown()

func (*NewTopicClientRequest) XXX_Marshal 

func (m *NewTopicClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewTopicClientRequest) XXX_Merge 

func (m *NewTopicClientRequest) XXX_Merge(src proto.Message)

func (*NewTopicClientRequest) XXX_Size 

func (m *NewTopicClientRequest) XXX_Size() int

func (*NewTopicClientRequest) XXX_Unmarshal 

func (m *NewTopicClientRequest) XXX_Unmarshal(b []byte) error

type NewTopicClientResponse 

type NewTopicClientResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewTopicClientResponse) Descriptor 

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

func (*NewTopicClientResponse) ProtoMessage 

func (*NewTopicClientResponse) ProtoMessage()

func (*NewTopicClientResponse) Reset 

func (m *NewTopicClientResponse) Reset()

func (*NewTopicClientResponse) String 

func (m *NewTopicClientResponse) String() string

func (*NewTopicClientResponse) XXX_DiscardUnknown 

func (m *NewTopicClientResponse) XXX_DiscardUnknown()

func (*NewTopicClientResponse) XXX_Marshal 

func (m *NewTopicClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewTopicClientResponse) XXX_Merge 

func (m *NewTopicClientResponse) XXX_Merge(src proto.Message)

func (*NewTopicClientResponse) XXX_Size 

func (m *NewTopicClientResponse) XXX_Size() int

func (*NewTopicClientResponse) XXX_Unmarshal 

func (m *NewTopicClientResponse) XXX_Unmarshal(b []byte) error

type NewTopicRequest 

type NewTopicRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewTopicRequest) Descriptor 

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

func (*NewTopicRequest) GetTopic 

func (m *NewTopicRequest) GetTopic() string

func (*NewTopicRequest) ProtoMessage 

func (*NewTopicRequest) ProtoMessage()

func (*NewTopicRequest) Reset 

func (m *NewTopicRequest) Reset()

func (*NewTopicRequest) String 

func (m *NewTopicRequest) String() string

func (*NewTopicRequest) XXX_DiscardUnknown 

func (m *NewTopicRequest) XXX_DiscardUnknown()

func (*NewTopicRequest) XXX_Marshal 

func (m *NewTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewTopicRequest) XXX_Merge 

func (m *NewTopicRequest) XXX_Merge(src proto.Message)

func (*NewTopicRequest) XXX_Size 

func (m *NewTopicRequest) XXX_Size() int

func (*NewTopicRequest) XXX_Unmarshal 

func (m *NewTopicRequest) XXX_Unmarshal(b []byte) error

type NewTopicResponse 

type NewTopicResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewTopicResponse) Descriptor 

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

func (*NewTopicResponse) ProtoMessage 

func (*NewTopicResponse) ProtoMessage()

func (*NewTopicResponse) Reset 

func (m *NewTopicResponse) Reset()

func (*NewTopicResponse) String 

func (m *NewTopicResponse) String() string

func (*NewTopicResponse) XXX_DiscardUnknown 

func (m *NewTopicResponse) XXX_DiscardUnknown()

func (*NewTopicResponse) XXX_Marshal 

func (m *NewTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewTopicResponse) XXX_Merge 

func (m *NewTopicResponse) XXX_Merge(src proto.Message)

func (*NewTopicResponse) XXX_Size 

func (m *NewTopicResponse) XXX_Size() int

func (*NewTopicResponse) XXX_Unmarshal 

func (m *NewTopicResponse) XXX_Unmarshal(b []byte) error

type ProtectMessageRequest 

type ProtectMessageRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	BinaryData           []byte   `protobuf:"bytes,2,opt,name=binaryData,proto3" json:"binaryData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProtectMessageRequest) Descriptor 

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

func (*ProtectMessageRequest) GetBinaryData 

func (m *ProtectMessageRequest) GetBinaryData() []byte

func (*ProtectMessageRequest) GetTopic 

func (m *ProtectMessageRequest) GetTopic() string

func (*ProtectMessageRequest) ProtoMessage 

func (*ProtectMessageRequest) ProtoMessage()

func (*ProtectMessageRequest) Reset 

func (m *ProtectMessageRequest) Reset()

func (*ProtectMessageRequest) String 

func (m *ProtectMessageRequest) String() string

func (*ProtectMessageRequest) XXX_DiscardUnknown 

func (m *ProtectMessageRequest) XXX_DiscardUnknown()

func (*ProtectMessageRequest) XXX_Marshal 

func (m *ProtectMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtectMessageRequest) XXX_Merge 

func (m *ProtectMessageRequest) XXX_Merge(src proto.Message)

func (*ProtectMessageRequest) XXX_Size 

func (m *ProtectMessageRequest) XXX_Size() int

func (*ProtectMessageRequest) XXX_Unmarshal 

func (m *ProtectMessageRequest) XXX_Unmarshal(b []byte) error

type ProtectMessageResponse 

type ProtectMessageResponse struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	ProtectedBinaryData  []byte   `protobuf:"bytes,2,opt,name=protectedBinaryData,proto3" json:"protectedBinaryData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProtectMessageResponse) Descriptor 

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

func (*ProtectMessageResponse) GetProtectedBinaryData 

func (m *ProtectMessageResponse) GetProtectedBinaryData() []byte

func (*ProtectMessageResponse) GetTopic 

func (m *ProtectMessageResponse) GetTopic() string

func (*ProtectMessageResponse) ProtoMessage 

func (*ProtectMessageResponse) ProtoMessage()

func (*ProtectMessageResponse) Reset 

func (m *ProtectMessageResponse) Reset()

func (*ProtectMessageResponse) String 

func (m *ProtectMessageResponse) String() string

func (*ProtectMessageResponse) XXX_DiscardUnknown 

func (m *ProtectMessageResponse) XXX_DiscardUnknown()

func (*ProtectMessageResponse) XXX_Marshal 

func (m *ProtectMessageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtectMessageResponse) XXX_Merge 

func (m *ProtectMessageResponse) XXX_Merge(src proto.Message)

func (*ProtectMessageResponse) XXX_Size 

func (m *ProtectMessageResponse) XXX_Size() int

func (*ProtectMessageResponse) XXX_Unmarshal 

func (m *ProtectMessageResponse) XXX_Unmarshal(b []byte) error

type RemoveClientPubKeyRequest 

type RemoveClientPubKeyRequest struct {
	SourceClient         *Client  `protobuf:"bytes,1,opt,name=sourceClient,proto3" json:"sourceClient,omitempty"`
	TargetClient         *Client  `protobuf:"bytes,2,opt,name=targetClient,proto3" json:"targetClient,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveClientPubKeyRequest) Descriptor 

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

func (*RemoveClientPubKeyRequest) GetSourceClient 

func (m *RemoveClientPubKeyRequest) GetSourceClient() *Client

func (*RemoveClientPubKeyRequest) GetTargetClient 

func (m *RemoveClientPubKeyRequest) GetTargetClient() *Client

func (*RemoveClientPubKeyRequest) ProtoMessage 

func (*RemoveClientPubKeyRequest) ProtoMessage()

func (*RemoveClientPubKeyRequest) Reset 

func (m *RemoveClientPubKeyRequest) Reset()

func (*RemoveClientPubKeyRequest) String 

func (m *RemoveClientPubKeyRequest) String() string

func (*RemoveClientPubKeyRequest) XXX_DiscardUnknown 

func (m *RemoveClientPubKeyRequest) XXX_DiscardUnknown()

func (*RemoveClientPubKeyRequest) XXX_Marshal 

func (m *RemoveClientPubKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveClientPubKeyRequest) XXX_Merge 

func (m *RemoveClientPubKeyRequest) XXX_Merge(src proto.Message)

func (*RemoveClientPubKeyRequest) XXX_Size 

func (m *RemoveClientPubKeyRequest) XXX_Size() int

func (*RemoveClientPubKeyRequest) XXX_Unmarshal 

func (m *RemoveClientPubKeyRequest) XXX_Unmarshal(b []byte) error

type RemoveClientPubKeyResponse 

type RemoveClientPubKeyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveClientPubKeyResponse) Descriptor 

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

func (*RemoveClientPubKeyResponse) ProtoMessage 

func (*RemoveClientPubKeyResponse) ProtoMessage()

func (*RemoveClientPubKeyResponse) Reset 

func (m *RemoveClientPubKeyResponse) Reset()

func (*RemoveClientPubKeyResponse) String 

func (m *RemoveClientPubKeyResponse) String() string

func (*RemoveClientPubKeyResponse) XXX_DiscardUnknown 

func (m *RemoveClientPubKeyResponse) XXX_DiscardUnknown()

func (*RemoveClientPubKeyResponse) XXX_Marshal 

func (m *RemoveClientPubKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveClientPubKeyResponse) XXX_Merge 

func (m *RemoveClientPubKeyResponse) XXX_Merge(src proto.Message)

func (*RemoveClientPubKeyResponse) XXX_Size 

func (m *RemoveClientPubKeyResponse) XXX_Size() int

func (*RemoveClientPubKeyResponse) XXX_Unmarshal 

func (m *RemoveClientPubKeyResponse) XXX_Unmarshal(b []byte) error

type RemoveClientRequest 

type RemoveClientRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveClientRequest) Descriptor 

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

func (*RemoveClientRequest) GetClient 

func (m *RemoveClientRequest) GetClient() *Client

func (*RemoveClientRequest) ProtoMessage 

func (*RemoveClientRequest) ProtoMessage()

func (*RemoveClientRequest) Reset 

func (m *RemoveClientRequest) Reset()

func (*RemoveClientRequest) String 

func (m *RemoveClientRequest) String() string

func (*RemoveClientRequest) XXX_DiscardUnknown 

func (m *RemoveClientRequest) XXX_DiscardUnknown()

func (*RemoveClientRequest) XXX_Marshal 

func (m *RemoveClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveClientRequest) XXX_Merge 

func (m *RemoveClientRequest) XXX_Merge(src proto.Message)

func (*RemoveClientRequest) XXX_Size 

func (m *RemoveClientRequest) XXX_Size() int

func (*RemoveClientRequest) XXX_Unmarshal 

func (m *RemoveClientRequest) XXX_Unmarshal(b []byte) error

type RemoveClientResponse 

type RemoveClientResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveClientResponse) Descriptor 

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

func (*RemoveClientResponse) ProtoMessage 

func (*RemoveClientResponse) ProtoMessage()

func (*RemoveClientResponse) Reset 

func (m *RemoveClientResponse) Reset()

func (*RemoveClientResponse) String 

func (m *RemoveClientResponse) String() string

func (*RemoveClientResponse) XXX_DiscardUnknown 

func (m *RemoveClientResponse) XXX_DiscardUnknown()

func (*RemoveClientResponse) XXX_Marshal 

func (m *RemoveClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveClientResponse) XXX_Merge 

func (m *RemoveClientResponse) XXX_Merge(src proto.Message)

func (*RemoveClientResponse) XXX_Size 

func (m *RemoveClientResponse) XXX_Size() int

func (*RemoveClientResponse) XXX_Unmarshal 

func (m *RemoveClientResponse) XXX_Unmarshal(b []byte) error

type RemoveTopicClientRequest 

type RemoveTopicClientRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Topic                string   `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveTopicClientRequest) Descriptor 

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

func (*RemoveTopicClientRequest) GetClient 

func (m *RemoveTopicClientRequest) GetClient() *Client

func (*RemoveTopicClientRequest) GetTopic 

func (m *RemoveTopicClientRequest) GetTopic() string

func (*RemoveTopicClientRequest) ProtoMessage 

func (*RemoveTopicClientRequest) ProtoMessage()

func (*RemoveTopicClientRequest) Reset 

func (m *RemoveTopicClientRequest) Reset()

func (*RemoveTopicClientRequest) String 

func (m *RemoveTopicClientRequest) String() string

func (*RemoveTopicClientRequest) XXX_DiscardUnknown 

func (m *RemoveTopicClientRequest) XXX_DiscardUnknown()

func (*RemoveTopicClientRequest) XXX_Marshal 

func (m *RemoveTopicClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveTopicClientRequest) XXX_Merge 

func (m *RemoveTopicClientRequest) XXX_Merge(src proto.Message)

func (*RemoveTopicClientRequest) XXX_Size 

func (m *RemoveTopicClientRequest) XXX_Size() int

func (*RemoveTopicClientRequest) XXX_Unmarshal 

func (m *RemoveTopicClientRequest) XXX_Unmarshal(b []byte) error

type RemoveTopicClientResponse 

type RemoveTopicClientResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveTopicClientResponse) Descriptor 

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

func (*RemoveTopicClientResponse) ProtoMessage 

func (*RemoveTopicClientResponse) ProtoMessage()

func (*RemoveTopicClientResponse) Reset 

func (m *RemoveTopicClientResponse) Reset()

func (*RemoveTopicClientResponse) String 

func (m *RemoveTopicClientResponse) String() string

func (*RemoveTopicClientResponse) XXX_DiscardUnknown 

func (m *RemoveTopicClientResponse) XXX_DiscardUnknown()

func (*RemoveTopicClientResponse) XXX_Marshal 

func (m *RemoveTopicClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveTopicClientResponse) XXX_Merge 

func (m *RemoveTopicClientResponse) XXX_Merge(src proto.Message)

func (*RemoveTopicClientResponse) XXX_Size 

func (m *RemoveTopicClientResponse) XXX_Size() int

func (*RemoveTopicClientResponse) XXX_Unmarshal 

func (m *RemoveTopicClientResponse) XXX_Unmarshal(b []byte) error

type RemoveTopicRequest 

type RemoveTopicRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveTopicRequest) Descriptor 

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

func (*RemoveTopicRequest) GetTopic 

func (m *RemoveTopicRequest) GetTopic() string

func (*RemoveTopicRequest) ProtoMessage 

func (*RemoveTopicRequest) ProtoMessage()

func (*RemoveTopicRequest) Reset 

func (m *RemoveTopicRequest) Reset()

func (*RemoveTopicRequest) String 

func (m *RemoveTopicRequest) String() string

func (*RemoveTopicRequest) XXX_DiscardUnknown 

func (m *RemoveTopicRequest) XXX_DiscardUnknown()

func (*RemoveTopicRequest) XXX_Marshal 

func (m *RemoveTopicRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveTopicRequest) XXX_Merge 

func (m *RemoveTopicRequest) XXX_Merge(src proto.Message)

func (*RemoveTopicRequest) XXX_Size 

func (m *RemoveTopicRequest) XXX_Size() int

func (*RemoveTopicRequest) XXX_Unmarshal 

func (m *RemoveTopicRequest) XXX_Unmarshal(b []byte) error

type RemoveTopicResponse 

type RemoveTopicResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveTopicResponse) Descriptor 

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

func (*RemoveTopicResponse) ProtoMessage 

func (*RemoveTopicResponse) ProtoMessage()

func (*RemoveTopicResponse) Reset 

func (m *RemoveTopicResponse) Reset()

func (*RemoveTopicResponse) String 

func (m *RemoveTopicResponse) String() string

func (*RemoveTopicResponse) XXX_DiscardUnknown 

func (m *RemoveTopicResponse) XXX_DiscardUnknown()

func (*RemoveTopicResponse) XXX_Marshal 

func (m *RemoveTopicResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveTopicResponse) XXX_Merge 

func (m *RemoveTopicResponse) XXX_Merge(src proto.Message)

func (*RemoveTopicResponse) XXX_Size 

func (m *RemoveTopicResponse) XXX_Size() int

func (*RemoveTopicResponse) XXX_Unmarshal 

func (m *RemoveTopicResponse) XXX_Unmarshal(b []byte) error

type ResetClientPubKeysRequest 

type ResetClientPubKeysRequest struct {
	TargetClient         *Client  `protobuf:"bytes,1,opt,name=targetClient,proto3" json:"targetClient,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetClientPubKeysRequest) Descriptor 

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

func (*ResetClientPubKeysRequest) GetTargetClient 

func (m *ResetClientPubKeysRequest) GetTargetClient() *Client

func (*ResetClientPubKeysRequest) ProtoMessage 

func (*ResetClientPubKeysRequest) ProtoMessage()

func (*ResetClientPubKeysRequest) Reset 

func (m *ResetClientPubKeysRequest) Reset()

func (*ResetClientPubKeysRequest) String 

func (m *ResetClientPubKeysRequest) String() string

func (*ResetClientPubKeysRequest) XXX_DiscardUnknown 

func (m *ResetClientPubKeysRequest) XXX_DiscardUnknown()

func (*ResetClientPubKeysRequest) XXX_Marshal 

func (m *ResetClientPubKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetClientPubKeysRequest) XXX_Merge 

func (m *ResetClientPubKeysRequest) XXX_Merge(src proto.Message)

func (*ResetClientPubKeysRequest) XXX_Size 

func (m *ResetClientPubKeysRequest) XXX_Size() int

func (*ResetClientPubKeysRequest) XXX_Unmarshal 

func (m *ResetClientPubKeysRequest) XXX_Unmarshal(b []byte) error

type ResetClientPubKeysResponse 

type ResetClientPubKeysResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetClientPubKeysResponse) Descriptor 

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

func (*ResetClientPubKeysResponse) ProtoMessage 

func (*ResetClientPubKeysResponse) ProtoMessage()

func (*ResetClientPubKeysResponse) Reset 

func (m *ResetClientPubKeysResponse) Reset()

func (*ResetClientPubKeysResponse) String 

func (m *ResetClientPubKeysResponse) String() string

func (*ResetClientPubKeysResponse) XXX_DiscardUnknown 

func (m *ResetClientPubKeysResponse) XXX_DiscardUnknown()

func (*ResetClientPubKeysResponse) XXX_Marshal 

func (m *ResetClientPubKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetClientPubKeysResponse) XXX_Merge 

func (m *ResetClientPubKeysResponse) XXX_Merge(src proto.Message)

func (*ResetClientPubKeysResponse) XXX_Size 

func (m *ResetClientPubKeysResponse) XXX_Size() int

func (*ResetClientPubKeysResponse) XXX_Unmarshal 

func (m *ResetClientPubKeysResponse) XXX_Unmarshal(b []byte) error

type ResetClientRequest 

type ResetClientRequest struct {
	Client               *Client  `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetClientRequest) Descriptor 

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

func (*ResetClientRequest) GetClient 

func (m *ResetClientRequest) GetClient() *Client

func (*ResetClientRequest) ProtoMessage 

func (*ResetClientRequest) ProtoMessage()

func (*ResetClientRequest) Reset 

func (m *ResetClientRequest) Reset()

func (*ResetClientRequest) String 

func (m *ResetClientRequest) String() string

func (*ResetClientRequest) XXX_DiscardUnknown 

func (m *ResetClientRequest) XXX_DiscardUnknown()

func (*ResetClientRequest) XXX_Marshal 

func (m *ResetClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetClientRequest) XXX_Merge 

func (m *ResetClientRequest) XXX_Merge(src proto.Message)

func (*ResetClientRequest) XXX_Size 

func (m *ResetClientRequest) XXX_Size() int

func (*ResetClientRequest) XXX_Unmarshal 

func (m *ResetClientRequest) XXX_Unmarshal(b []byte) error

type ResetClientResponse 

type ResetClientResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetClientResponse) Descriptor 

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

func (*ResetClientResponse) ProtoMessage 

func (*ResetClientResponse) ProtoMessage()

func (*ResetClientResponse) Reset 

func (m *ResetClientResponse) Reset()

func (*ResetClientResponse) String 

func (m *ResetClientResponse) String() string

func (*ResetClientResponse) XXX_DiscardUnknown 

func (m *ResetClientResponse) XXX_DiscardUnknown()

func (*ResetClientResponse) XXX_Marshal 

func (m *ResetClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetClientResponse) XXX_Merge 

func (m *ResetClientResponse) XXX_Merge(src proto.Message)

func (*ResetClientResponse) XXX_Size 

func (m *ResetClientResponse) XXX_Size() int

func (*ResetClientResponse) XXX_Unmarshal 

func (m *ResetClientResponse) XXX_Unmarshal(b []byte) error

type SendClientPubKeyRequest 

type SendClientPubKeyRequest struct {
	SourceClient         *Client  `protobuf:"bytes,1,opt,name=sourceClient,proto3" json:"sourceClient,omitempty"`
	TargetClient         *Client  `protobuf:"bytes,2,opt,name=targetClient,proto3" json:"targetClient,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendClientPubKeyRequest) Descriptor 

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

func (*SendClientPubKeyRequest) GetSourceClient 

func (m *SendClientPubKeyRequest) GetSourceClient() *Client

func (*SendClientPubKeyRequest) GetTargetClient 

func (m *SendClientPubKeyRequest) GetTargetClient() *Client

func (*SendClientPubKeyRequest) ProtoMessage 

func (*SendClientPubKeyRequest) ProtoMessage()

func (*SendClientPubKeyRequest) Reset 

func (m *SendClientPubKeyRequest) Reset()

func (*SendClientPubKeyRequest) String 

func (m *SendClientPubKeyRequest) String() string

func (*SendClientPubKeyRequest) XXX_DiscardUnknown 

func (m *SendClientPubKeyRequest) XXX_DiscardUnknown()

func (*SendClientPubKeyRequest) XXX_Marshal 

func (m *SendClientPubKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendClientPubKeyRequest) XXX_Merge 

func (m *SendClientPubKeyRequest) XXX_Merge(src proto.Message)

func (*SendClientPubKeyRequest) XXX_Size 

func (m *SendClientPubKeyRequest) XXX_Size() int

func (*SendClientPubKeyRequest) XXX_Unmarshal 

func (m *SendClientPubKeyRequest) XXX_Unmarshal(b []byte) error

type SendClientPubKeyResponse 

type SendClientPubKeyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendClientPubKeyResponse) Descriptor 

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

func (*SendClientPubKeyResponse) ProtoMessage 

func (*SendClientPubKeyResponse) ProtoMessage()

func (*SendClientPubKeyResponse) Reset 

func (m *SendClientPubKeyResponse) Reset()

func (*SendClientPubKeyResponse) String 

func (m *SendClientPubKeyResponse) String() string

func (*SendClientPubKeyResponse) XXX_DiscardUnknown 

func (m *SendClientPubKeyResponse) XXX_DiscardUnknown()

func (*SendClientPubKeyResponse) XXX_Marshal 

func (m *SendClientPubKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendClientPubKeyResponse) XXX_Merge 

func (m *SendClientPubKeyResponse) XXX_Merge(src proto.Message)

func (*SendClientPubKeyResponse) XXX_Size 

func (m *SendClientPubKeyResponse) XXX_Size() int

func (*SendClientPubKeyResponse) XXX_Unmarshal 

func (m *SendClientPubKeyResponse) XXX_Unmarshal(b []byte) error

type SubscribeToEventStreamRequest 

type SubscribeToEventStreamRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeToEventStreamRequest) Descriptor 

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

func (*SubscribeToEventStreamRequest) ProtoMessage 

func (*SubscribeToEventStreamRequest) ProtoMessage()

func (*SubscribeToEventStreamRequest) Reset 

func (m *SubscribeToEventStreamRequest) Reset()

func (*SubscribeToEventStreamRequest) String 

func (m *SubscribeToEventStreamRequest) String() string

func (*SubscribeToEventStreamRequest) XXX_DiscardUnknown 

func (m *SubscribeToEventStreamRequest) XXX_DiscardUnknown()

func (*SubscribeToEventStreamRequest) XXX_Marshal 

func (m *SubscribeToEventStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeToEventStreamRequest) XXX_Merge 

func (m *SubscribeToEventStreamRequest) XXX_Merge(src proto.Message)

func (*SubscribeToEventStreamRequest) XXX_Size 

func (m *SubscribeToEventStreamRequest) XXX_Size() int

func (*SubscribeToEventStreamRequest) XXX_Unmarshal 

func (m *SubscribeToEventStreamRequest) XXX_Unmarshal(b []byte) error

type UnimplementedC2Server 

type UnimplementedC2Server struct {
}

UnimplementedC2Server can be embedded to have forward compatible implementations.

func (*UnimplementedC2Server) CountClients 

func (*UnimplementedC2Server) CountClients(ctx context.Context, req *CountClientsRequest) (*CountClientsResponse, error)

func (*UnimplementedC2Server) CountClientsForTopic 

func (*UnimplementedC2Server) CountClientsForTopic(ctx context.Context, req *CountClientsForTopicRequest) (*CountClientsForTopicResponse, error)

func (*UnimplementedC2Server) CountLinkedClients 

func (*UnimplementedC2Server) CountLinkedClients(ctx context.Context, req *CountLinkedClientsRequest) (*CountLinkedClientsResponse, error)

func (*UnimplementedC2Server) CountTopics 

func (*UnimplementedC2Server) CountTopics(ctx context.Context, req *CountTopicsRequest) (*CountTopicsResponse, error)

func (*UnimplementedC2Server) CountTopicsForClient 

func (*UnimplementedC2Server) CountTopicsForClient(ctx context.Context, req *CountTopicsForClientRequest) (*CountTopicsForClientResponse, error)

func (*UnimplementedC2Server) GetClients 

func (*UnimplementedC2Server) GetClients(ctx context.Context, req *GetClientsRequest) (*GetClientsResponse, error)

func (*UnimplementedC2Server) GetClientsForTopic 

func (*UnimplementedC2Server) GetClientsForTopic(ctx context.Context, req *GetClientsForTopicRequest) (*GetClientsForTopicResponse, error)

func (*UnimplementedC2Server) GetCryptoMode 

func (*UnimplementedC2Server) GetCryptoMode(ctx context.Context, req *GetCryptoModeRequest) (*GetCryptoModeResponse, error)

func (*UnimplementedC2Server) GetLinkedClients 

func (*UnimplementedC2Server) GetLinkedClients(ctx context.Context, req *GetLinkedClientsRequest) (*GetLinkedClientsResponse, error)

func (*UnimplementedC2Server) GetTopics 

func (*UnimplementedC2Server) GetTopics(ctx context.Context, req *GetTopicsRequest) (*GetTopicsResponse, error)

func (*UnimplementedC2Server) GetTopicsForClient 

func (*UnimplementedC2Server) GetTopicsForClient(ctx context.Context, req *GetTopicsForClientRequest) (*GetTopicsForClientResponse, error)

func (*UnimplementedC2Server) HealthCheck 

func (*UnimplementedC2Server) HealthCheck(ctx context.Context, req *HealthCheckRequest) (*HealthCheckResponse, error)

func (*UnimplementedC2Server) LinkClient 

func (*UnimplementedC2Server) LinkClient(ctx context.Context, req *LinkClientRequest) (*LinkClientResponse, error)

func (*UnimplementedC2Server) NewC2Key 

func (*UnimplementedC2Server) NewC2Key(ctx context.Context, req *NewC2KeyRequest) (*NewC2KeyResponse, error)

func (*UnimplementedC2Server) NewClient 

func (*UnimplementedC2Server) NewClient(ctx context.Context, req *NewClientRequest) (*NewClientResponse, error)

func (*UnimplementedC2Server) NewClientKey 

func (*UnimplementedC2Server) NewClientKey(ctx context.Context, req *NewClientKeyRequest) (*NewClientKeyResponse, error)

func (*UnimplementedC2Server) NewTopic 

func (*UnimplementedC2Server) NewTopic(ctx context.Context, req *NewTopicRequest) (*NewTopicResponse, error)

func (*UnimplementedC2Server) NewTopicClient 

func (*UnimplementedC2Server) NewTopicClient(ctx context.Context, req *NewTopicClientRequest) (*NewTopicClientResponse, error)

func (*UnimplementedC2Server) ProtectMessage 

func (*UnimplementedC2Server) ProtectMessage(ctx context.Context, req *ProtectMessageRequest) (*ProtectMessageResponse, error)

func (*UnimplementedC2Server) RemoveClient 

func (*UnimplementedC2Server) RemoveClient(ctx context.Context, req *RemoveClientRequest) (*RemoveClientResponse, error)

func (*UnimplementedC2Server) RemoveClientPubKey 

func (*UnimplementedC2Server) RemoveClientPubKey(ctx context.Context, req *RemoveClientPubKeyRequest) (*RemoveClientPubKeyResponse, error)

func (*UnimplementedC2Server) RemoveTopic 

func (*UnimplementedC2Server) RemoveTopic(ctx context.Context, req *RemoveTopicRequest) (*RemoveTopicResponse, error)

func (*UnimplementedC2Server) RemoveTopicClient 

func (*UnimplementedC2Server) RemoveTopicClient(ctx context.Context, req *RemoveTopicClientRequest) (*RemoveTopicClientResponse, error)

func (*UnimplementedC2Server) ResetClient 

func (*UnimplementedC2Server) ResetClient(ctx context.Context, req *ResetClientRequest) (*ResetClientResponse, error)

func (*UnimplementedC2Server) ResetClientPubKeys 

func (*UnimplementedC2Server) ResetClientPubKeys(ctx context.Context, req *ResetClientPubKeysRequest) (*ResetClientPubKeysResponse, error)

func (*UnimplementedC2Server) SendClientPubKey 

func (*UnimplementedC2Server) SendClientPubKey(ctx context.Context, req *SendClientPubKeyRequest) (*SendClientPubKeyResponse, error)

func (*UnimplementedC2Server) SubscribeToEventStream 

func (*UnimplementedC2Server) SubscribeToEventStream(req *SubscribeToEventStreamRequest, srv C2_SubscribeToEventStreamServer) error

func (*UnimplementedC2Server) UnlinkClient 

func (*UnimplementedC2Server) UnlinkClient(ctx context.Context, req *UnlinkClientRequest) (*UnlinkClientResponse, error)

func (*UnimplementedC2Server) UnprotectMessage 

func (*UnimplementedC2Server) UnprotectMessage(ctx context.Context, req *UnprotectMessageRequest) (*UnprotectMessageResponse, error)

type UnlinkClientRequest 

type UnlinkClientRequest struct {
	SourceClient         *Client  `protobuf:"bytes,1,opt,name=sourceClient,proto3" json:"sourceClient,omitempty"`
	TargetClient         *Client  `protobuf:"bytes,2,opt,name=targetClient,proto3" json:"targetClient,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnlinkClientRequest) Descriptor 

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

func (*UnlinkClientRequest) GetSourceClient 

func (m *UnlinkClientRequest) GetSourceClient() *Client

func (*UnlinkClientRequest) GetTargetClient 

func (m *UnlinkClientRequest) GetTargetClient() *Client

func (*UnlinkClientRequest) ProtoMessage 

func (*UnlinkClientRequest) ProtoMessage()

func (*UnlinkClientRequest) Reset 

func (m *UnlinkClientRequest) Reset()

func (*UnlinkClientRequest) String 

func (m *UnlinkClientRequest) String() string

func (*UnlinkClientRequest) XXX_DiscardUnknown 

func (m *UnlinkClientRequest) XXX_DiscardUnknown()

func (*UnlinkClientRequest) XXX_Marshal 

func (m *UnlinkClientRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlinkClientRequest) XXX_Merge 

func (m *UnlinkClientRequest) XXX_Merge(src proto.Message)

func (*UnlinkClientRequest) XXX_Size 

func (m *UnlinkClientRequest) XXX_Size() int

func (*UnlinkClientRequest) XXX_Unmarshal 

func (m *UnlinkClientRequest) XXX_Unmarshal(b []byte) error

type UnlinkClientResponse 

type UnlinkClientResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnlinkClientResponse) Descriptor 

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

func (*UnlinkClientResponse) ProtoMessage 

func (*UnlinkClientResponse) ProtoMessage()

func (*UnlinkClientResponse) Reset 

func (m *UnlinkClientResponse) Reset()

func (*UnlinkClientResponse) String 

func (m *UnlinkClientResponse) String() string

func (*UnlinkClientResponse) XXX_DiscardUnknown 

func (m *UnlinkClientResponse) XXX_DiscardUnknown()

func (*UnlinkClientResponse) XXX_Marshal 

func (m *UnlinkClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlinkClientResponse) XXX_Merge 

func (m *UnlinkClientResponse) XXX_Merge(src proto.Message)

func (*UnlinkClientResponse) XXX_Size 

func (m *UnlinkClientResponse) XXX_Size() int

func (*UnlinkClientResponse) XXX_Unmarshal 

func (m *UnlinkClientResponse) XXX_Unmarshal(b []byte) error

type UnprotectMessageRequest 

type UnprotectMessageRequest struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	ProtectedBinaryData  []byte   `protobuf:"bytes,2,opt,name=protectedBinaryData,proto3" json:"protectedBinaryData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnprotectMessageRequest) Descriptor 

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

func (*UnprotectMessageRequest) GetProtectedBinaryData 

func (m *UnprotectMessageRequest) GetProtectedBinaryData() []byte

func (*UnprotectMessageRequest) GetTopic 

func (m *UnprotectMessageRequest) GetTopic() string

func (*UnprotectMessageRequest) ProtoMessage 

func (*UnprotectMessageRequest) ProtoMessage()

func (*UnprotectMessageRequest) Reset 

func (m *UnprotectMessageRequest) Reset()

func (*UnprotectMessageRequest) String 

func (m *UnprotectMessageRequest) String() string

func (*UnprotectMessageRequest) XXX_DiscardUnknown 

func (m *UnprotectMessageRequest) XXX_DiscardUnknown()

func (*UnprotectMessageRequest) XXX_Marshal 

func (m *UnprotectMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnprotectMessageRequest) XXX_Merge 

func (m *UnprotectMessageRequest) XXX_Merge(src proto.Message)

func (*UnprotectMessageRequest) XXX_Size 

func (m *UnprotectMessageRequest) XXX_Size() int

func (*UnprotectMessageRequest) XXX_Unmarshal 

func (m *UnprotectMessageRequest) XXX_Unmarshal(b []byte) error

type UnprotectMessageResponse 

type UnprotectMessageResponse struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	BinaryData           []byte   `protobuf:"bytes,2,opt,name=binaryData,proto3" json:"binaryData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnprotectMessageResponse) Descriptor 

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

func (*UnprotectMessageResponse) GetBinaryData 

func (m *UnprotectMessageResponse) GetBinaryData() []byte

func (*UnprotectMessageResponse) GetTopic 

func (m *UnprotectMessageResponse) GetTopic() string

func (*UnprotectMessageResponse) ProtoMessage 

func (*UnprotectMessageResponse) ProtoMessage()

func (*UnprotectMessageResponse) Reset 

func (m *UnprotectMessageResponse) Reset()

func (*UnprotectMessageResponse) String 

func (m *UnprotectMessageResponse) String() string

func (*UnprotectMessageResponse) XXX_DiscardUnknown 

func (m *UnprotectMessageResponse) XXX_DiscardUnknown()

func (*UnprotectMessageResponse) XXX_Marshal 

func (m *UnprotectMessageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnprotectMessageResponse) XXX_Merge 

func (m *UnprotectMessageResponse) XXX_Merge(src proto.Message)

func (*UnprotectMessageResponse) XXX_Size 

func (m *UnprotectMessageResponse) XXX_Size() int

func (*UnprotectMessageResponse) XXX_Unmarshal 

func (m *UnprotectMessageResponse) XXX_Unmarshal(b []byte) error

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.