pb

package
v0.0.63-rc65 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2019 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrSessionNotFound = errors.New("session not found in store")
)

Functions

func RegisterSessionsServiceServer 

func RegisterSessionsServiceServer(s *grpc.Server, srv SessionsServiceServer)

Types

type Client 

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

func NewClient 

func NewClient(conn *grpc.ClientConn) *Client

func (*Client) All 

func (c *Client) All(ctx context.Context) ([]*Session, error)

func (*Client) ByClientID 

func (c *Client) ByClientID(ctx context.Context, id string) ([]*Session, error)

func (*Client) ByID 

func (c *Client) ByID(ctx context.Context, id string) (*Session, error)

func (*Client) ByPeer 

func (c *Client) ByPeer(ctx context.Context, id string) ([]*Session, error)

func (*Client) Create 

func (c *Client) Create(ctx context.Context, input SessionCreateInput) error

func (*Client) Delete 

func (c *Client) Delete(ctx context.Context, id string) error

type Session 

type Session struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Tenant               string   `protobuf:"bytes,2,opt,name=Tenant,proto3" json:"Tenant,omitempty"`
	Peer                 string   `protobuf:"bytes,3,opt,name=Peer,proto3" json:"Peer,omitempty"`
	WillTopic            []byte   `protobuf:"bytes,4,opt,name=WillTopic,proto3" json:"WillTopic,omitempty"`
	WillQoS              int32    `protobuf:"varint,5,opt,name=WillQoS,proto3" json:"WillQoS,omitempty"`
	WillPayload          []byte   `protobuf:"bytes,6,opt,name=WillPayload,proto3" json:"WillPayload,omitempty"`
	WillRetain           bool     `protobuf:"varint,7,opt,name=WillRetain,proto3" json:"WillRetain,omitempty"`
	Created              int64    `protobuf:"varint,8,opt,name=Created,proto3" json:"Created,omitempty"`
	ClientID             string   `protobuf:"bytes,9,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	LastAdded            int64    `protobuf:"varint,10,opt,name=LastAdded,proto3" json:"LastAdded,omitempty"`
	LastDeleted          int64    `protobuf:"varint,11,opt,name=LastDeleted,proto3" json:"LastDeleted,omitempty"`
	Transport            string   `protobuf:"bytes,12,opt,name=Transport,proto3" json:"Transport,omitempty"`
	RemoteAddress        string   `protobuf:"bytes,13,opt,name=RemoteAddress,proto3" json:"RemoteAddress,omitempty"`
	ClosureReason        string   `protobuf:"bytes,14,opt,name=ClosureReason,proto3" json:"ClosureReason,omitempty"`
	KeepaliveInterval    int32    `protobuf:"varint,15,opt,name=KeepaliveInterval,proto3" json:"KeepaliveInterval,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Session) Descriptor 

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

func (*Session) GetClientID 

func (m *Session) GetClientID() string

func (*Session) GetClosureReason 

func (m *Session) GetClosureReason() string

func (*Session) GetCreated 

func (m *Session) GetCreated() int64

func (*Session) GetID 

func (m *Session) GetID() string

func (*Session) GetKeepaliveInterval 

func (m *Session) GetKeepaliveInterval() int32

func (*Session) GetLastAdded added in v0.0.71 

func (m *Session) GetLastAdded() int64

func (*Session) GetLastDeleted added in v0.0.71 

func (m *Session) GetLastDeleted() int64

func (*Session) GetPeer 

func (m *Session) GetPeer() string

func (*Session) GetRemoteAddress 

func (m *Session) GetRemoteAddress() string

func (*Session) GetTenant 

func (m *Session) GetTenant() string

func (*Session) GetTransport 

func (m *Session) GetTransport() string

func (*Session) GetWillPayload 

func (m *Session) GetWillPayload() []byte

func (*Session) GetWillQoS 

func (m *Session) GetWillQoS() int32

func (*Session) GetWillRetain 

func (m *Session) GetWillRetain() bool

func (*Session) GetWillTopic 

func (m *Session) GetWillTopic() []byte

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

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

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type SessionByClientIDInput 

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

func (*SessionByClientIDInput) Descriptor 

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

func (*SessionByClientIDInput) GetClientID 

func (m *SessionByClientIDInput) GetClientID() string

func (*SessionByClientIDInput) ProtoMessage 

func (*SessionByClientIDInput) ProtoMessage()

func (*SessionByClientIDInput) Reset 

func (m *SessionByClientIDInput) Reset()

func (*SessionByClientIDInput) String 

func (m *SessionByClientIDInput) String() string

func (*SessionByClientIDInput) XXX_DiscardUnknown 

func (m *SessionByClientIDInput) XXX_DiscardUnknown()

func (*SessionByClientIDInput) XXX_Marshal 

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

func (*SessionByClientIDInput) XXX_Merge 

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

func (*SessionByClientIDInput) XXX_Size 

func (m *SessionByClientIDInput) XXX_Size() int

func (*SessionByClientIDInput) XXX_Unmarshal 

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

type SessionByIDInput 

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

func (*SessionByIDInput) Descriptor 

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

func (*SessionByIDInput) GetID 

func (m *SessionByIDInput) GetID() string

func (*SessionByIDInput) ProtoMessage 

func (*SessionByIDInput) ProtoMessage()

func (*SessionByIDInput) Reset 

func (m *SessionByIDInput) Reset()

func (*SessionByIDInput) String 

func (m *SessionByIDInput) String() string

func (*SessionByIDInput) XXX_DiscardUnknown 

func (m *SessionByIDInput) XXX_DiscardUnknown()

func (*SessionByIDInput) XXX_Marshal 

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

func (*SessionByIDInput) XXX_Merge 

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

func (*SessionByIDInput) XXX_Size 

func (m *SessionByIDInput) XXX_Size() int

func (*SessionByIDInput) XXX_Unmarshal 

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

type SessionByPeerInput 

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

func (*SessionByPeerInput) Descriptor 

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

func (*SessionByPeerInput) GetPeer 

func (m *SessionByPeerInput) GetPeer() string

func (*SessionByPeerInput) ProtoMessage 

func (*SessionByPeerInput) ProtoMessage()

func (*SessionByPeerInput) Reset 

func (m *SessionByPeerInput) Reset()

func (*SessionByPeerInput) String 

func (m *SessionByPeerInput) String() string

func (*SessionByPeerInput) XXX_DiscardUnknown 

func (m *SessionByPeerInput) XXX_DiscardUnknown()

func (*SessionByPeerInput) XXX_Marshal 

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

func (*SessionByPeerInput) XXX_Merge 

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

func (*SessionByPeerInput) XXX_Size 

func (m *SessionByPeerInput) XXX_Size() int

func (*SessionByPeerInput) XXX_Unmarshal 

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

type SessionCreateInput 

type SessionCreateInput struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Tenant               string   `protobuf:"bytes,2,opt,name=Tenant,proto3" json:"Tenant,omitempty"`
	Peer                 string   `protobuf:"bytes,3,opt,name=Peer,proto3" json:"Peer,omitempty"`
	WillTopic            []byte   `protobuf:"bytes,4,opt,name=WillTopic,proto3" json:"WillTopic,omitempty"`
	WillQoS              int32    `protobuf:"varint,5,opt,name=WillQoS,proto3" json:"WillQoS,omitempty"`
	WillPayload          []byte   `protobuf:"bytes,6,opt,name=WillPayload,proto3" json:"WillPayload,omitempty"`
	WillRetain           bool     `protobuf:"varint,7,opt,name=WillRetain,proto3" json:"WillRetain,omitempty"`
	ClientID             string   `protobuf:"bytes,9,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Transport            string   `protobuf:"bytes,10,opt,name=Transport,proto3" json:"Transport,omitempty"`
	RemoteAddress        string   `protobuf:"bytes,11,opt,name=RemoteAddress,proto3" json:"RemoteAddress,omitempty"`
	KeepaliveInterval    int32    `protobuf:"varint,12,opt,name=KeepaliveInterval,proto3" json:"KeepaliveInterval,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SessionCreateInput) Descriptor 

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

func (*SessionCreateInput) GetClientID 

func (m *SessionCreateInput) GetClientID() string

func (*SessionCreateInput) GetID 

func (m *SessionCreateInput) GetID() string

func (*SessionCreateInput) GetKeepaliveInterval 

func (m *SessionCreateInput) GetKeepaliveInterval() int32

func (*SessionCreateInput) GetPeer 

func (m *SessionCreateInput) GetPeer() string

func (*SessionCreateInput) GetRemoteAddress 

func (m *SessionCreateInput) GetRemoteAddress() string

func (*SessionCreateInput) GetTenant 

func (m *SessionCreateInput) GetTenant() string

func (*SessionCreateInput) GetTransport 

func (m *SessionCreateInput) GetTransport() string

func (*SessionCreateInput) GetWillPayload 

func (m *SessionCreateInput) GetWillPayload() []byte

func (*SessionCreateInput) GetWillQoS 

func (m *SessionCreateInput) GetWillQoS() int32

func (*SessionCreateInput) GetWillRetain 

func (m *SessionCreateInput) GetWillRetain() bool

func (*SessionCreateInput) GetWillTopic 

func (m *SessionCreateInput) GetWillTopic() []byte

func (*SessionCreateInput) ProtoMessage 

func (*SessionCreateInput) ProtoMessage()

func (*SessionCreateInput) Reset 

func (m *SessionCreateInput) Reset()

func (*SessionCreateInput) String 

func (m *SessionCreateInput) String() string

func (*SessionCreateInput) XXX_DiscardUnknown 

func (m *SessionCreateInput) XXX_DiscardUnknown()

func (*SessionCreateInput) XXX_Marshal 

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

func (*SessionCreateInput) XXX_Merge 

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

func (*SessionCreateInput) XXX_Size 

func (m *SessionCreateInput) XXX_Size() int

func (*SessionCreateInput) XXX_Unmarshal 

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

type SessionCreateOutput 

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

func (*SessionCreateOutput) Descriptor 

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

func (*SessionCreateOutput) ProtoMessage 

func (*SessionCreateOutput) ProtoMessage()

func (*SessionCreateOutput) Reset 

func (m *SessionCreateOutput) Reset()

func (*SessionCreateOutput) String 

func (m *SessionCreateOutput) String() string

func (*SessionCreateOutput) XXX_DiscardUnknown 

func (m *SessionCreateOutput) XXX_DiscardUnknown()

func (*SessionCreateOutput) XXX_Marshal 

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

func (*SessionCreateOutput) XXX_Merge 

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

func (*SessionCreateOutput) XXX_Size 

func (m *SessionCreateOutput) XXX_Size() int

func (*SessionCreateOutput) XXX_Unmarshal 

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

type SessionDeleteInput 

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

func (*SessionDeleteInput) Descriptor 

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

func (*SessionDeleteInput) GetID 

func (m *SessionDeleteInput) GetID() string

func (*SessionDeleteInput) ProtoMessage 

func (*SessionDeleteInput) ProtoMessage()

func (*SessionDeleteInput) Reset 

func (m *SessionDeleteInput) Reset()

func (*SessionDeleteInput) String 

func (m *SessionDeleteInput) String() string

func (*SessionDeleteInput) XXX_DiscardUnknown 

func (m *SessionDeleteInput) XXX_DiscardUnknown()

func (*SessionDeleteInput) XXX_Marshal 

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

func (*SessionDeleteInput) XXX_Merge 

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

func (*SessionDeleteInput) XXX_Size 

func (m *SessionDeleteInput) XXX_Size() int

func (*SessionDeleteInput) XXX_Unmarshal 

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

type SessionDeleteOutput 

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

func (*SessionDeleteOutput) Descriptor 

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

func (*SessionDeleteOutput) ProtoMessage 

func (*SessionDeleteOutput) ProtoMessage()

func (*SessionDeleteOutput) Reset 

func (m *SessionDeleteOutput) Reset()

func (*SessionDeleteOutput) String 

func (m *SessionDeleteOutput) String() string

func (*SessionDeleteOutput) XXX_DiscardUnknown 

func (m *SessionDeleteOutput) XXX_DiscardUnknown()

func (*SessionDeleteOutput) XXX_Marshal 

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

func (*SessionDeleteOutput) XXX_Merge 

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

func (*SessionDeleteOutput) XXX_Size 

func (m *SessionDeleteOutput) XXX_Size() int

func (*SessionDeleteOutput) XXX_Unmarshal 

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

type SessionFilterInput 

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

func (*SessionFilterInput) Descriptor 

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

func (*SessionFilterInput) ProtoMessage 

func (*SessionFilterInput) ProtoMessage()

func (*SessionFilterInput) Reset 

func (m *SessionFilterInput) Reset()

func (*SessionFilterInput) String 

func (m *SessionFilterInput) String() string

func (*SessionFilterInput) XXX_DiscardUnknown 

func (m *SessionFilterInput) XXX_DiscardUnknown()

func (*SessionFilterInput) XXX_Marshal 

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

func (*SessionFilterInput) XXX_Merge 

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

func (*SessionFilterInput) XXX_Size 

func (m *SessionFilterInput) XXX_Size() int

func (*SessionFilterInput) XXX_Unmarshal 

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

type SessionMetadataList 

type SessionMetadataList struct {
	Sessions             []*Session `protobuf:"bytes,1,rep,name=Sessions,proto3" json:"Sessions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SessionMetadataList) Descriptor 

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

func (*SessionMetadataList) GetSessions 

func (m *SessionMetadataList) GetSessions() []*Session

func (*SessionMetadataList) ProtoMessage 

func (*SessionMetadataList) ProtoMessage()

func (*SessionMetadataList) Reset 

func (m *SessionMetadataList) Reset()

func (*SessionMetadataList) String 

func (m *SessionMetadataList) String() string

func (*SessionMetadataList) XXX_DiscardUnknown 

func (m *SessionMetadataList) XXX_DiscardUnknown()

func (*SessionMetadataList) XXX_Marshal 

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

func (*SessionMetadataList) XXX_Merge 

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

func (*SessionMetadataList) XXX_Size 

func (m *SessionMetadataList) XXX_Size() int

func (*SessionMetadataList) XXX_Unmarshal 

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

type SessionStateTransition 

type SessionStateTransition struct {
	Kind                 string                                `protobuf:"bytes,1,opt,name=Kind,proto3" json:"Kind,omitempty"`
	SessionCreated       *SessionStateTransitionSessionCreated `protobuf:"bytes,2,opt,name=SessionCreated,proto3" json:"SessionCreated,omitempty"`
	SessionDeleted       *SessionStateTransitionSessionDeleted `protobuf:"bytes,3,opt,name=SessionDeleted,proto3" json:"SessionDeleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*SessionStateTransition) Descriptor 

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

func (*SessionStateTransition) GetKind 

func (m *SessionStateTransition) GetKind() string

func (*SessionStateTransition) GetSessionCreated 

func (m *SessionStateTransition) GetSessionCreated() *SessionStateTransitionSessionCreated

func (*SessionStateTransition) GetSessionDeleted 

func (m *SessionStateTransition) GetSessionDeleted() *SessionStateTransitionSessionDeleted

func (*SessionStateTransition) ProtoMessage 

func (*SessionStateTransition) ProtoMessage()

func (*SessionStateTransition) Reset 

func (m *SessionStateTransition) Reset()

func (*SessionStateTransition) String 

func (m *SessionStateTransition) String() string

func (*SessionStateTransition) XXX_DiscardUnknown 

func (m *SessionStateTransition) XXX_DiscardUnknown()

func (*SessionStateTransition) XXX_Marshal 

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

func (*SessionStateTransition) XXX_Merge 

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

func (*SessionStateTransition) XXX_Size 

func (m *SessionStateTransition) XXX_Size() int

func (*SessionStateTransition) XXX_Unmarshal 

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

type SessionStateTransitionSessionCreated 

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

func (*SessionStateTransitionSessionCreated) Descriptor 

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

func (*SessionStateTransitionSessionCreated) GetInput 

func (m *SessionStateTransitionSessionCreated) GetInput() *SessionCreateInput

func (*SessionStateTransitionSessionCreated) ProtoMessage 

func (*SessionStateTransitionSessionCreated) ProtoMessage()

func (*SessionStateTransitionSessionCreated) Reset 

func (m *SessionStateTransitionSessionCreated) Reset()

func (*SessionStateTransitionSessionCreated) String 

func (m *SessionStateTransitionSessionCreated) String() string

func (*SessionStateTransitionSessionCreated) XXX_DiscardUnknown 

func (m *SessionStateTransitionSessionCreated) XXX_DiscardUnknown()

func (*SessionStateTransitionSessionCreated) XXX_Marshal 

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

func (*SessionStateTransitionSessionCreated) XXX_Merge 

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

func (*SessionStateTransitionSessionCreated) XXX_Size 

func (m *SessionStateTransitionSessionCreated) XXX_Size() int

func (*SessionStateTransitionSessionCreated) XXX_Unmarshal 

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

type SessionStateTransitionSessionDeleted 

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

func (*SessionStateTransitionSessionDeleted) Descriptor 

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

func (*SessionStateTransitionSessionDeleted) GetID 

func (m *SessionStateTransitionSessionDeleted) GetID() string

func (*SessionStateTransitionSessionDeleted) ProtoMessage 

func (*SessionStateTransitionSessionDeleted) ProtoMessage()

func (*SessionStateTransitionSessionDeleted) Reset 

func (m *SessionStateTransitionSessionDeleted) Reset()

func (*SessionStateTransitionSessionDeleted) String 

func (m *SessionStateTransitionSessionDeleted) String() string

func (*SessionStateTransitionSessionDeleted) XXX_DiscardUnknown 

func (m *SessionStateTransitionSessionDeleted) XXX_DiscardUnknown()

func (*SessionStateTransitionSessionDeleted) XXX_Marshal 

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

func (*SessionStateTransitionSessionDeleted) XXX_Merge 

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

func (*SessionStateTransitionSessionDeleted) XXX_Size 

func (m *SessionStateTransitionSessionDeleted) XXX_Size() int

func (*SessionStateTransitionSessionDeleted) XXX_Unmarshal 

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

type SessionsServiceClient 

type SessionsServiceClient interface {
	Create(ctx context.Context, in *SessionCreateInput, opts ...grpc.CallOption) (*SessionCreateOutput, error)
	Delete(ctx context.Context, in *SessionDeleteInput, opts ...grpc.CallOption) (*SessionDeleteOutput, error)
	ByID(ctx context.Context, in *SessionByIDInput, opts ...grpc.CallOption) (*Session, error)
	ByClientID(ctx context.Context, in *SessionByClientIDInput, opts ...grpc.CallOption) (*SessionMetadataList, error)
	ByPeer(ctx context.Context, in *SessionByPeerInput, opts ...grpc.CallOption) (*SessionMetadataList, error)
	All(ctx context.Context, in *SessionFilterInput, opts ...grpc.CallOption) (*SessionMetadataList, error)
}

SessionsServiceClient is the client API for SessionsService service.

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

func NewSessionsServiceClient 

func NewSessionsServiceClient(cc *grpc.ClientConn) SessionsServiceClient

type SessionsServiceServer 

type SessionsServiceServer interface {
	Create(context.Context, *SessionCreateInput) (*SessionCreateOutput, error)
	Delete(context.Context, *SessionDeleteInput) (*SessionDeleteOutput, error)
	ByID(context.Context, *SessionByIDInput) (*Session, error)
	ByClientID(context.Context, *SessionByClientIDInput) (*SessionMetadataList, error)
	ByPeer(context.Context, *SessionByPeerInput) (*SessionMetadataList, error)
	All(context.Context, *SessionFilterInput) (*SessionMetadataList, error)
}

SessionsServiceServer is the server API for SessionsService service.

type UnimplementedSessionsServiceServer 

type UnimplementedSessionsServiceServer struct {
}

UnimplementedSessionsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSessionsServiceServer) All 

func (*UnimplementedSessionsServiceServer) All(ctx context.Context, req *SessionFilterInput) (*SessionMetadataList, error)

func (*UnimplementedSessionsServiceServer) ByClientID 

func (*UnimplementedSessionsServiceServer) ByClientID(ctx context.Context, req *SessionByClientIDInput) (*SessionMetadataList, error)

func (*UnimplementedSessionsServiceServer) ByID 

func (*UnimplementedSessionsServiceServer) ByID(ctx context.Context, req *SessionByIDInput) (*Session, error)

func (*UnimplementedSessionsServiceServer) ByPeer 

func (*UnimplementedSessionsServiceServer) ByPeer(ctx context.Context, req *SessionByPeerInput) (*SessionMetadataList, error)

func (*UnimplementedSessionsServiceServer) Create 

func (*UnimplementedSessionsServiceServer) Create(ctx context.Context, req *SessionCreateInput) (*SessionCreateOutput, error)

func (*UnimplementedSessionsServiceServer) Delete 

func (*UnimplementedSessionsServiceServer) Delete(ctx context.Context, req *SessionDeleteInput) (*SessionDeleteOutput, 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.