Documentation
      ¶
    
    
  
    
  
    Index ¶
- func RegisterHandlerServiceServer(s *grpc.Server, srv HandlerServiceServer)
 - type AddInboundRequest
 - func (*AddInboundRequest) Descriptor() ([]byte, []int)
 - func (m *AddInboundRequest) GetInbound() *core.InboundHandlerConfig
 - func (*AddInboundRequest) ProtoMessage()
 - func (m *AddInboundRequest) Reset()
 - func (m *AddInboundRequest) String() string
 - func (m *AddInboundRequest) XXX_DiscardUnknown()
 - func (m *AddInboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AddInboundRequest) XXX_Merge(src proto.Message)
 - func (m *AddInboundRequest) XXX_Size() int
 - func (m *AddInboundRequest) XXX_Unmarshal(b []byte) error
 
- type AddInboundResponse
 - func (*AddInboundResponse) Descriptor() ([]byte, []int)
 - func (*AddInboundResponse) ProtoMessage()
 - func (m *AddInboundResponse) Reset()
 - func (m *AddInboundResponse) String() string
 - func (m *AddInboundResponse) XXX_DiscardUnknown()
 - func (m *AddInboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AddInboundResponse) XXX_Merge(src proto.Message)
 - func (m *AddInboundResponse) XXX_Size() int
 - func (m *AddInboundResponse) XXX_Unmarshal(b []byte) error
 
- type AddOutboundRequest
 - func (*AddOutboundRequest) Descriptor() ([]byte, []int)
 - func (m *AddOutboundRequest) GetOutbound() *core.OutboundHandlerConfig
 - func (*AddOutboundRequest) ProtoMessage()
 - func (m *AddOutboundRequest) Reset()
 - func (m *AddOutboundRequest) String() string
 - func (m *AddOutboundRequest) XXX_DiscardUnknown()
 - func (m *AddOutboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AddOutboundRequest) XXX_Merge(src proto.Message)
 - func (m *AddOutboundRequest) XXX_Size() int
 - func (m *AddOutboundRequest) XXX_Unmarshal(b []byte) error
 
- type AddOutboundResponse
 - func (*AddOutboundResponse) Descriptor() ([]byte, []int)
 - func (*AddOutboundResponse) ProtoMessage()
 - func (m *AddOutboundResponse) Reset()
 - func (m *AddOutboundResponse) String() string
 - func (m *AddOutboundResponse) XXX_DiscardUnknown()
 - func (m *AddOutboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AddOutboundResponse) XXX_Merge(src proto.Message)
 - func (m *AddOutboundResponse) XXX_Size() int
 - func (m *AddOutboundResponse) XXX_Unmarshal(b []byte) error
 
- type AddUserOperation
 - func (op *AddUserOperation) ApplyInbound(ctx context.Context, handler inbound.Handler) error
 - func (*AddUserOperation) Descriptor() ([]byte, []int)
 - func (m *AddUserOperation) GetUser() *protocol.User
 - func (*AddUserOperation) ProtoMessage()
 - func (m *AddUserOperation) Reset()
 - func (m *AddUserOperation) String() string
 - func (m *AddUserOperation) XXX_DiscardUnknown()
 - func (m *AddUserOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AddUserOperation) XXX_Merge(src proto.Message)
 - func (m *AddUserOperation) XXX_Size() int
 - func (m *AddUserOperation) XXX_Unmarshal(b []byte) error
 
- type AlterInboundRequest
 - func (*AlterInboundRequest) Descriptor() ([]byte, []int)
 - func (m *AlterInboundRequest) GetOperation() *serial.TypedMessage
 - func (m *AlterInboundRequest) GetTag() string
 - func (*AlterInboundRequest) ProtoMessage()
 - func (m *AlterInboundRequest) Reset()
 - func (m *AlterInboundRequest) String() string
 - func (m *AlterInboundRequest) XXX_DiscardUnknown()
 - func (m *AlterInboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AlterInboundRequest) XXX_Merge(src proto.Message)
 - func (m *AlterInboundRequest) XXX_Size() int
 - func (m *AlterInboundRequest) XXX_Unmarshal(b []byte) error
 
- type AlterInboundResponse
 - func (*AlterInboundResponse) Descriptor() ([]byte, []int)
 - func (*AlterInboundResponse) ProtoMessage()
 - func (m *AlterInboundResponse) Reset()
 - func (m *AlterInboundResponse) String() string
 - func (m *AlterInboundResponse) XXX_DiscardUnknown()
 - func (m *AlterInboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AlterInboundResponse) XXX_Merge(src proto.Message)
 - func (m *AlterInboundResponse) XXX_Size() int
 - func (m *AlterInboundResponse) XXX_Unmarshal(b []byte) error
 
- type AlterOutboundRequest
 - func (*AlterOutboundRequest) Descriptor() ([]byte, []int)
 - func (m *AlterOutboundRequest) GetOperation() *serial.TypedMessage
 - func (m *AlterOutboundRequest) GetTag() string
 - func (*AlterOutboundRequest) ProtoMessage()
 - func (m *AlterOutboundRequest) Reset()
 - func (m *AlterOutboundRequest) String() string
 - func (m *AlterOutboundRequest) XXX_DiscardUnknown()
 - func (m *AlterOutboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AlterOutboundRequest) XXX_Merge(src proto.Message)
 - func (m *AlterOutboundRequest) XXX_Size() int
 - func (m *AlterOutboundRequest) XXX_Unmarshal(b []byte) error
 
- type AlterOutboundResponse
 - func (*AlterOutboundResponse) Descriptor() ([]byte, []int)
 - func (*AlterOutboundResponse) ProtoMessage()
 - func (m *AlterOutboundResponse) Reset()
 - func (m *AlterOutboundResponse) String() string
 - func (m *AlterOutboundResponse) XXX_DiscardUnknown()
 - func (m *AlterOutboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *AlterOutboundResponse) XXX_Merge(src proto.Message)
 - func (m *AlterOutboundResponse) XXX_Size() int
 - func (m *AlterOutboundResponse) XXX_Unmarshal(b []byte) error
 
- type Config
 - func (*Config) Descriptor() ([]byte, []int)
 - func (*Config) ProtoMessage()
 - func (m *Config) Reset()
 - func (m *Config) String() string
 - func (m *Config) XXX_DiscardUnknown()
 - func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *Config) XXX_Merge(src proto.Message)
 - func (m *Config) XXX_Size() int
 - func (m *Config) XXX_Unmarshal(b []byte) error
 
- type HandlerServiceClient
 - type HandlerServiceServer
 - type InboundOperation
 - type OutboundOperation
 - type RemoveInboundRequest
 - func (*RemoveInboundRequest) Descriptor() ([]byte, []int)
 - func (m *RemoveInboundRequest) GetTag() string
 - func (*RemoveInboundRequest) ProtoMessage()
 - func (m *RemoveInboundRequest) Reset()
 - func (m *RemoveInboundRequest) String() string
 - func (m *RemoveInboundRequest) XXX_DiscardUnknown()
 - func (m *RemoveInboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *RemoveInboundRequest) XXX_Merge(src proto.Message)
 - func (m *RemoveInboundRequest) XXX_Size() int
 - func (m *RemoveInboundRequest) XXX_Unmarshal(b []byte) error
 
- type RemoveInboundResponse
 - func (*RemoveInboundResponse) Descriptor() ([]byte, []int)
 - func (*RemoveInboundResponse) ProtoMessage()
 - func (m *RemoveInboundResponse) Reset()
 - func (m *RemoveInboundResponse) String() string
 - func (m *RemoveInboundResponse) XXX_DiscardUnknown()
 - func (m *RemoveInboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *RemoveInboundResponse) XXX_Merge(src proto.Message)
 - func (m *RemoveInboundResponse) XXX_Size() int
 - func (m *RemoveInboundResponse) XXX_Unmarshal(b []byte) error
 
- type RemoveOutboundRequest
 - func (*RemoveOutboundRequest) Descriptor() ([]byte, []int)
 - func (m *RemoveOutboundRequest) GetTag() string
 - func (*RemoveOutboundRequest) ProtoMessage()
 - func (m *RemoveOutboundRequest) Reset()
 - func (m *RemoveOutboundRequest) String() string
 - func (m *RemoveOutboundRequest) XXX_DiscardUnknown()
 - func (m *RemoveOutboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *RemoveOutboundRequest) XXX_Merge(src proto.Message)
 - func (m *RemoveOutboundRequest) XXX_Size() int
 - func (m *RemoveOutboundRequest) XXX_Unmarshal(b []byte) error
 
- type RemoveOutboundResponse
 - func (*RemoveOutboundResponse) Descriptor() ([]byte, []int)
 - func (*RemoveOutboundResponse) ProtoMessage()
 - func (m *RemoveOutboundResponse) Reset()
 - func (m *RemoveOutboundResponse) String() string
 - func (m *RemoveOutboundResponse) XXX_DiscardUnknown()
 - func (m *RemoveOutboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *RemoveOutboundResponse) XXX_Merge(src proto.Message)
 - func (m *RemoveOutboundResponse) XXX_Size() int
 - func (m *RemoveOutboundResponse) XXX_Unmarshal(b []byte) error
 
- type RemoveUserOperation
 - func (op *RemoveUserOperation) ApplyInbound(ctx context.Context, handler inbound.Handler) error
 - func (*RemoveUserOperation) Descriptor() ([]byte, []int)
 - func (m *RemoveUserOperation) GetEmail() string
 - func (*RemoveUserOperation) ProtoMessage()
 - func (m *RemoveUserOperation) Reset()
 - func (m *RemoveUserOperation) String() string
 - func (m *RemoveUserOperation) XXX_DiscardUnknown()
 - func (m *RemoveUserOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *RemoveUserOperation) XXX_Merge(src proto.Message)
 - func (m *RemoveUserOperation) XXX_Size() int
 - func (m *RemoveUserOperation) XXX_Unmarshal(b []byte) error
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterHandlerServiceServer ¶
func RegisterHandlerServiceServer(s *grpc.Server, srv HandlerServiceServer)
Types ¶
type AddInboundRequest ¶
type AddInboundRequest struct {
	Inbound              *core.InboundHandlerConfig `protobuf:"bytes,1,opt,name=inbound,proto3" json:"inbound,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}
    func (*AddInboundRequest) Descriptor ¶
func (*AddInboundRequest) Descriptor() ([]byte, []int)
func (*AddInboundRequest) GetInbound ¶
func (m *AddInboundRequest) GetInbound() *core.InboundHandlerConfig
func (*AddInboundRequest) ProtoMessage ¶
func (*AddInboundRequest) ProtoMessage()
func (*AddInboundRequest) Reset ¶
func (m *AddInboundRequest) Reset()
func (*AddInboundRequest) String ¶
func (m *AddInboundRequest) String() string
func (*AddInboundRequest) XXX_DiscardUnknown ¶
func (m *AddInboundRequest) XXX_DiscardUnknown()
func (*AddInboundRequest) XXX_Marshal ¶
func (m *AddInboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddInboundRequest) XXX_Merge ¶
func (m *AddInboundRequest) XXX_Merge(src proto.Message)
func (*AddInboundRequest) XXX_Size ¶
func (m *AddInboundRequest) XXX_Size() int
func (*AddInboundRequest) XXX_Unmarshal ¶
func (m *AddInboundRequest) XXX_Unmarshal(b []byte) error
type AddInboundResponse ¶
type AddInboundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*AddInboundResponse) Descriptor ¶
func (*AddInboundResponse) Descriptor() ([]byte, []int)
func (*AddInboundResponse) ProtoMessage ¶
func (*AddInboundResponse) ProtoMessage()
func (*AddInboundResponse) Reset ¶
func (m *AddInboundResponse) Reset()
func (*AddInboundResponse) String ¶
func (m *AddInboundResponse) String() string
func (*AddInboundResponse) XXX_DiscardUnknown ¶
func (m *AddInboundResponse) XXX_DiscardUnknown()
func (*AddInboundResponse) XXX_Marshal ¶
func (m *AddInboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddInboundResponse) XXX_Merge ¶
func (m *AddInboundResponse) XXX_Merge(src proto.Message)
func (*AddInboundResponse) XXX_Size ¶
func (m *AddInboundResponse) XXX_Size() int
func (*AddInboundResponse) XXX_Unmarshal ¶
func (m *AddInboundResponse) XXX_Unmarshal(b []byte) error
type AddOutboundRequest ¶
type AddOutboundRequest struct {
	Outbound             *core.OutboundHandlerConfig `protobuf:"bytes,1,opt,name=outbound,proto3" json:"outbound,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}
    func (*AddOutboundRequest) Descriptor ¶
func (*AddOutboundRequest) Descriptor() ([]byte, []int)
func (*AddOutboundRequest) GetOutbound ¶
func (m *AddOutboundRequest) GetOutbound() *core.OutboundHandlerConfig
func (*AddOutboundRequest) ProtoMessage ¶
func (*AddOutboundRequest) ProtoMessage()
func (*AddOutboundRequest) Reset ¶
func (m *AddOutboundRequest) Reset()
func (*AddOutboundRequest) String ¶
func (m *AddOutboundRequest) String() string
func (*AddOutboundRequest) XXX_DiscardUnknown ¶
func (m *AddOutboundRequest) XXX_DiscardUnknown()
func (*AddOutboundRequest) XXX_Marshal ¶
func (m *AddOutboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddOutboundRequest) XXX_Merge ¶
func (m *AddOutboundRequest) XXX_Merge(src proto.Message)
func (*AddOutboundRequest) XXX_Size ¶
func (m *AddOutboundRequest) XXX_Size() int
func (*AddOutboundRequest) XXX_Unmarshal ¶
func (m *AddOutboundRequest) XXX_Unmarshal(b []byte) error
type AddOutboundResponse ¶
type AddOutboundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*AddOutboundResponse) Descriptor ¶
func (*AddOutboundResponse) Descriptor() ([]byte, []int)
func (*AddOutboundResponse) ProtoMessage ¶
func (*AddOutboundResponse) ProtoMessage()
func (*AddOutboundResponse) Reset ¶
func (m *AddOutboundResponse) Reset()
func (*AddOutboundResponse) String ¶
func (m *AddOutboundResponse) String() string
func (*AddOutboundResponse) XXX_DiscardUnknown ¶
func (m *AddOutboundResponse) XXX_DiscardUnknown()
func (*AddOutboundResponse) XXX_Marshal ¶
func (m *AddOutboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddOutboundResponse) XXX_Merge ¶
func (m *AddOutboundResponse) XXX_Merge(src proto.Message)
func (*AddOutboundResponse) XXX_Size ¶
func (m *AddOutboundResponse) XXX_Size() int
func (*AddOutboundResponse) XXX_Unmarshal ¶
func (m *AddOutboundResponse) XXX_Unmarshal(b []byte) error
type AddUserOperation ¶
type AddUserOperation struct {
	User                 *protocol.User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}
    func (*AddUserOperation) ApplyInbound ¶
ApplyInbound implements InboundOperation.
func (*AddUserOperation) Descriptor ¶
func (*AddUserOperation) Descriptor() ([]byte, []int)
func (*AddUserOperation) GetUser ¶
func (m *AddUserOperation) GetUser() *protocol.User
func (*AddUserOperation) ProtoMessage ¶
func (*AddUserOperation) ProtoMessage()
func (*AddUserOperation) Reset ¶
func (m *AddUserOperation) Reset()
func (*AddUserOperation) String ¶
func (m *AddUserOperation) String() string
func (*AddUserOperation) XXX_DiscardUnknown ¶
func (m *AddUserOperation) XXX_DiscardUnknown()
func (*AddUserOperation) XXX_Marshal ¶
func (m *AddUserOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddUserOperation) XXX_Merge ¶
func (m *AddUserOperation) XXX_Merge(src proto.Message)
func (*AddUserOperation) XXX_Size ¶
func (m *AddUserOperation) XXX_Size() int
func (*AddUserOperation) XXX_Unmarshal ¶
func (m *AddUserOperation) XXX_Unmarshal(b []byte) error
type AlterInboundRequest ¶
type AlterInboundRequest struct {
	Tag                  string               `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Operation            *serial.TypedMessage `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}
    func (*AlterInboundRequest) Descriptor ¶
func (*AlterInboundRequest) Descriptor() ([]byte, []int)
func (*AlterInboundRequest) GetOperation ¶
func (m *AlterInboundRequest) GetOperation() *serial.TypedMessage
func (*AlterInboundRequest) GetTag ¶
func (m *AlterInboundRequest) GetTag() string
func (*AlterInboundRequest) ProtoMessage ¶
func (*AlterInboundRequest) ProtoMessage()
func (*AlterInboundRequest) Reset ¶
func (m *AlterInboundRequest) Reset()
func (*AlterInboundRequest) String ¶
func (m *AlterInboundRequest) String() string
func (*AlterInboundRequest) XXX_DiscardUnknown ¶
func (m *AlterInboundRequest) XXX_DiscardUnknown()
func (*AlterInboundRequest) XXX_Marshal ¶
func (m *AlterInboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterInboundRequest) XXX_Merge ¶
func (m *AlterInboundRequest) XXX_Merge(src proto.Message)
func (*AlterInboundRequest) XXX_Size ¶
func (m *AlterInboundRequest) XXX_Size() int
func (*AlterInboundRequest) XXX_Unmarshal ¶
func (m *AlterInboundRequest) XXX_Unmarshal(b []byte) error
type AlterInboundResponse ¶
type AlterInboundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*AlterInboundResponse) Descriptor ¶
func (*AlterInboundResponse) Descriptor() ([]byte, []int)
func (*AlterInboundResponse) ProtoMessage ¶
func (*AlterInboundResponse) ProtoMessage()
func (*AlterInboundResponse) Reset ¶
func (m *AlterInboundResponse) Reset()
func (*AlterInboundResponse) String ¶
func (m *AlterInboundResponse) String() string
func (*AlterInboundResponse) XXX_DiscardUnknown ¶
func (m *AlterInboundResponse) XXX_DiscardUnknown()
func (*AlterInboundResponse) XXX_Marshal ¶
func (m *AlterInboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterInboundResponse) XXX_Merge ¶
func (m *AlterInboundResponse) XXX_Merge(src proto.Message)
func (*AlterInboundResponse) XXX_Size ¶
func (m *AlterInboundResponse) XXX_Size() int
func (*AlterInboundResponse) XXX_Unmarshal ¶
func (m *AlterInboundResponse) XXX_Unmarshal(b []byte) error
type AlterOutboundRequest ¶
type AlterOutboundRequest struct {
	Tag                  string               `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Operation            *serial.TypedMessage `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}
    func (*AlterOutboundRequest) Descriptor ¶
func (*AlterOutboundRequest) Descriptor() ([]byte, []int)
func (*AlterOutboundRequest) GetOperation ¶
func (m *AlterOutboundRequest) GetOperation() *serial.TypedMessage
func (*AlterOutboundRequest) GetTag ¶
func (m *AlterOutboundRequest) GetTag() string
func (*AlterOutboundRequest) ProtoMessage ¶
func (*AlterOutboundRequest) ProtoMessage()
func (*AlterOutboundRequest) Reset ¶
func (m *AlterOutboundRequest) Reset()
func (*AlterOutboundRequest) String ¶
func (m *AlterOutboundRequest) String() string
func (*AlterOutboundRequest) XXX_DiscardUnknown ¶
func (m *AlterOutboundRequest) XXX_DiscardUnknown()
func (*AlterOutboundRequest) XXX_Marshal ¶
func (m *AlterOutboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterOutboundRequest) XXX_Merge ¶
func (m *AlterOutboundRequest) XXX_Merge(src proto.Message)
func (*AlterOutboundRequest) XXX_Size ¶
func (m *AlterOutboundRequest) XXX_Size() int
func (*AlterOutboundRequest) XXX_Unmarshal ¶
func (m *AlterOutboundRequest) XXX_Unmarshal(b []byte) error
type AlterOutboundResponse ¶
type AlterOutboundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*AlterOutboundResponse) Descriptor ¶
func (*AlterOutboundResponse) Descriptor() ([]byte, []int)
func (*AlterOutboundResponse) ProtoMessage ¶
func (*AlterOutboundResponse) ProtoMessage()
func (*AlterOutboundResponse) Reset ¶
func (m *AlterOutboundResponse) Reset()
func (*AlterOutboundResponse) String ¶
func (m *AlterOutboundResponse) String() string
func (*AlterOutboundResponse) XXX_DiscardUnknown ¶
func (m *AlterOutboundResponse) XXX_DiscardUnknown()
func (*AlterOutboundResponse) XXX_Marshal ¶
func (m *AlterOutboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AlterOutboundResponse) XXX_Merge ¶
func (m *AlterOutboundResponse) XXX_Merge(src proto.Message)
func (*AlterOutboundResponse) XXX_Size ¶
func (m *AlterOutboundResponse) XXX_Size() int
func (*AlterOutboundResponse) XXX_Unmarshal ¶
func (m *AlterOutboundResponse) XXX_Unmarshal(b []byte) error
type Config ¶
type Config struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*Config) XXX_Marshal ¶
type HandlerServiceClient ¶
type HandlerServiceClient interface {
	AddInbound(ctx context.Context, in *AddInboundRequest, opts ...grpc.CallOption) (*AddInboundResponse, error)
	RemoveInbound(ctx context.Context, in *RemoveInboundRequest, opts ...grpc.CallOption) (*RemoveInboundResponse, error)
	AlterInbound(ctx context.Context, in *AlterInboundRequest, opts ...grpc.CallOption) (*AlterInboundResponse, error)
	AddOutbound(ctx context.Context, in *AddOutboundRequest, opts ...grpc.CallOption) (*AddOutboundResponse, error)
	RemoveOutbound(ctx context.Context, in *RemoveOutboundRequest, opts ...grpc.CallOption) (*RemoveOutboundResponse, error)
	AlterOutbound(ctx context.Context, in *AlterOutboundRequest, opts ...grpc.CallOption) (*AlterOutboundResponse, error)
}
    HandlerServiceClient is the client API for HandlerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewHandlerServiceClient ¶
func NewHandlerServiceClient(cc *grpc.ClientConn) HandlerServiceClient
type HandlerServiceServer ¶
type HandlerServiceServer interface {
	AddInbound(context.Context, *AddInboundRequest) (*AddInboundResponse, error)
	RemoveInbound(context.Context, *RemoveInboundRequest) (*RemoveInboundResponse, error)
	AlterInbound(context.Context, *AlterInboundRequest) (*AlterInboundResponse, error)
	AddOutbound(context.Context, *AddOutboundRequest) (*AddOutboundResponse, error)
	RemoveOutbound(context.Context, *RemoveOutboundRequest) (*RemoveOutboundResponse, error)
	AlterOutbound(context.Context, *AlterOutboundRequest) (*AlterOutboundResponse, error)
}
    HandlerServiceServer is the server API for HandlerService service.
type InboundOperation ¶
type InboundOperation interface {
	// ApplyInbound applies this operation to the given inbound handler.
	ApplyInbound(context.Context, inbound.Handler) error
}
    InboundOperation is the interface for operations that applies to inbound handlers.
type OutboundOperation ¶
type OutboundOperation interface {
	// ApplyOutbound applies this operation to the given outbound handler.
	ApplyOutbound(context.Context, outbound.Handler) error
}
    OutboundOperation is the interface for operations that applies to outbound handlers.
type RemoveInboundRequest ¶
type RemoveInboundRequest struct {
	Tag                  string   `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*RemoveInboundRequest) Descriptor ¶
func (*RemoveInboundRequest) Descriptor() ([]byte, []int)
func (*RemoveInboundRequest) GetTag ¶
func (m *RemoveInboundRequest) GetTag() string
func (*RemoveInboundRequest) ProtoMessage ¶
func (*RemoveInboundRequest) ProtoMessage()
func (*RemoveInboundRequest) Reset ¶
func (m *RemoveInboundRequest) Reset()
func (*RemoveInboundRequest) String ¶
func (m *RemoveInboundRequest) String() string
func (*RemoveInboundRequest) XXX_DiscardUnknown ¶
func (m *RemoveInboundRequest) XXX_DiscardUnknown()
func (*RemoveInboundRequest) XXX_Marshal ¶
func (m *RemoveInboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveInboundRequest) XXX_Merge ¶
func (m *RemoveInboundRequest) XXX_Merge(src proto.Message)
func (*RemoveInboundRequest) XXX_Size ¶
func (m *RemoveInboundRequest) XXX_Size() int
func (*RemoveInboundRequest) XXX_Unmarshal ¶
func (m *RemoveInboundRequest) XXX_Unmarshal(b []byte) error
type RemoveInboundResponse ¶
type RemoveInboundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*RemoveInboundResponse) Descriptor ¶
func (*RemoveInboundResponse) Descriptor() ([]byte, []int)
func (*RemoveInboundResponse) ProtoMessage ¶
func (*RemoveInboundResponse) ProtoMessage()
func (*RemoveInboundResponse) Reset ¶
func (m *RemoveInboundResponse) Reset()
func (*RemoveInboundResponse) String ¶
func (m *RemoveInboundResponse) String() string
func (*RemoveInboundResponse) XXX_DiscardUnknown ¶
func (m *RemoveInboundResponse) XXX_DiscardUnknown()
func (*RemoveInboundResponse) XXX_Marshal ¶
func (m *RemoveInboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveInboundResponse) XXX_Merge ¶
func (m *RemoveInboundResponse) XXX_Merge(src proto.Message)
func (*RemoveInboundResponse) XXX_Size ¶
func (m *RemoveInboundResponse) XXX_Size() int
func (*RemoveInboundResponse) XXX_Unmarshal ¶
func (m *RemoveInboundResponse) XXX_Unmarshal(b []byte) error
type RemoveOutboundRequest ¶
type RemoveOutboundRequest struct {
	Tag                  string   `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*RemoveOutboundRequest) Descriptor ¶
func (*RemoveOutboundRequest) Descriptor() ([]byte, []int)
func (*RemoveOutboundRequest) GetTag ¶
func (m *RemoveOutboundRequest) GetTag() string
func (*RemoveOutboundRequest) ProtoMessage ¶
func (*RemoveOutboundRequest) ProtoMessage()
func (*RemoveOutboundRequest) Reset ¶
func (m *RemoveOutboundRequest) Reset()
func (*RemoveOutboundRequest) String ¶
func (m *RemoveOutboundRequest) String() string
func (*RemoveOutboundRequest) XXX_DiscardUnknown ¶
func (m *RemoveOutboundRequest) XXX_DiscardUnknown()
func (*RemoveOutboundRequest) XXX_Marshal ¶
func (m *RemoveOutboundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveOutboundRequest) XXX_Merge ¶
func (m *RemoveOutboundRequest) XXX_Merge(src proto.Message)
func (*RemoveOutboundRequest) XXX_Size ¶
func (m *RemoveOutboundRequest) XXX_Size() int
func (*RemoveOutboundRequest) XXX_Unmarshal ¶
func (m *RemoveOutboundRequest) XXX_Unmarshal(b []byte) error
type RemoveOutboundResponse ¶
type RemoveOutboundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*RemoveOutboundResponse) Descriptor ¶
func (*RemoveOutboundResponse) Descriptor() ([]byte, []int)
func (*RemoveOutboundResponse) ProtoMessage ¶
func (*RemoveOutboundResponse) ProtoMessage()
func (*RemoveOutboundResponse) Reset ¶
func (m *RemoveOutboundResponse) Reset()
func (*RemoveOutboundResponse) String ¶
func (m *RemoveOutboundResponse) String() string
func (*RemoveOutboundResponse) XXX_DiscardUnknown ¶
func (m *RemoveOutboundResponse) XXX_DiscardUnknown()
func (*RemoveOutboundResponse) XXX_Marshal ¶
func (m *RemoveOutboundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveOutboundResponse) XXX_Merge ¶
func (m *RemoveOutboundResponse) XXX_Merge(src proto.Message)
func (*RemoveOutboundResponse) XXX_Size ¶
func (m *RemoveOutboundResponse) XXX_Size() int
func (*RemoveOutboundResponse) XXX_Unmarshal ¶
func (m *RemoveOutboundResponse) XXX_Unmarshal(b []byte) error
type RemoveUserOperation ¶
type RemoveUserOperation struct {
	Email                string   `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    func (*RemoveUserOperation) ApplyInbound ¶
ApplyInbound implements InboundOperation.
func (*RemoveUserOperation) Descriptor ¶
func (*RemoveUserOperation) Descriptor() ([]byte, []int)
func (*RemoveUserOperation) GetEmail ¶
func (m *RemoveUserOperation) GetEmail() string
func (*RemoveUserOperation) ProtoMessage ¶
func (*RemoveUserOperation) ProtoMessage()
func (*RemoveUserOperation) Reset ¶
func (m *RemoveUserOperation) Reset()
func (*RemoveUserOperation) String ¶
func (m *RemoveUserOperation) String() string
func (*RemoveUserOperation) XXX_DiscardUnknown ¶
func (m *RemoveUserOperation) XXX_DiscardUnknown()
func (*RemoveUserOperation) XXX_Marshal ¶
func (m *RemoveUserOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveUserOperation) XXX_Merge ¶
func (m *RemoveUserOperation) XXX_Merge(src proto.Message)
func (*RemoveUserOperation) XXX_Size ¶
func (m *RemoveUserOperation) XXX_Size() int
func (*RemoveUserOperation) XXX_Unmarshal ¶
func (m *RemoveUserOperation) XXX_Unmarshal(b []byte) error
      
      Source Files
      ¶
    
- command.go
 - command.pb.go
 - doc.go
 - errors.generated.go
 
 Click to show internal directories. 
   Click to hide internal directories.