status

package
v0.0.0-...-e41513e Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRPCStatusServer 

func RegisterRPCStatusServer(s *grpc.Server, srv RPCStatusServer)

Types

type Int32 

type Int32 struct {
	V                    int32    `protobuf:"varint,1,opt,name=v,proto3" json:"v,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

//////////////////////////////////////////////////////////////////////////////////////

func (*Int32) Descriptor 

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

func (*Int32) GetV 

func (m *Int32) GetV() int32

func (*Int32) ProtoMessage 

func (*Int32) ProtoMessage()

func (*Int32) Reset 

func (m *Int32) Reset()

func (*Int32) String 

func (m *Int32) String() string

func (*Int32) XXX_DiscardUnknown 

func (m *Int32) XXX_DiscardUnknown()

func (*Int32) XXX_Marshal 

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

func (*Int32) XXX_Merge 

func (dst *Int32) XXX_Merge(src proto.Message)

func (*Int32) XXX_Size 

func (m *Int32) XXX_Size() int

func (*Int32) XXX_Unmarshal 

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

type Int32List 

type Int32List struct {
	Vlist                []int32  `protobuf:"varint,1,rep,packed,name=vlist,proto3" json:"vlist,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Int32List) Descriptor 

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

func (*Int32List) GetVlist 

func (m *Int32List) GetVlist() []int32

func (*Int32List) ProtoMessage 

func (*Int32List) ProtoMessage()

func (*Int32List) Reset 

func (m *Int32List) Reset()

func (*Int32List) String 

func (m *Int32List) String() string

func (*Int32List) XXX_DiscardUnknown 

func (m *Int32List) XXX_DiscardUnknown()

func (*Int32List) XXX_Marshal 

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

func (*Int32List) XXX_Merge 

func (dst *Int32List) XXX_Merge(src proto.Message)

func (*Int32List) XXX_Size 

func (m *Int32List) XXX_Size() int

func (*Int32List) XXX_Unmarshal 

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

type Int64List 

type Int64List struct {
	Vlist                []int64  `protobuf:"varint,1,rep,packed,name=vlist,proto3" json:"vlist,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Int64List) Descriptor 

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

func (*Int64List) GetVlist 

func (m *Int64List) GetVlist() []int64

func (*Int64List) ProtoMessage 

func (*Int64List) ProtoMessage()

func (*Int64List) Reset 

func (m *Int64List) Reset()

func (*Int64List) String 

func (m *Int64List) String() string

func (*Int64List) XXX_DiscardUnknown 

func (m *Int64List) XXX_DiscardUnknown()

func (*Int64List) XXX_Marshal 

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

func (*Int64List) XXX_Merge 

func (dst *Int64List) XXX_Merge(src proto.Message)

func (*Int64List) XXX_Size 

func (m *Int64List) XXX_Size() int

func (*Int64List) XXX_Unmarshal 

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

type RPCStatusClient 

type RPCStatusClient interface {
	SetSessionOnline(ctx context.Context, in *SessionEntry, opts ...grpc.CallOption) (*Void, error)
	SetSessionOffline(ctx context.Context, in *SessionEntry, opts ...grpc.CallOption) (*Void, error)
	GetUserOnlineSessions(ctx context.Context, in *Int32, opts ...grpc.CallOption) (*SessionEntryList, error)
	GetUsersOnlineSessionsList(ctx context.Context, in *Int32List, opts ...grpc.CallOption) (*UsersSessionEntryList, error)
}

RPCStatusClient is the client API for RPCStatus service.

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

func NewRPCStatusClient 

func NewRPCStatusClient(cc *grpc.ClientConn) RPCStatusClient

type RPCStatusServer 

type RPCStatusServer interface {
	SetSessionOnline(context.Context, *SessionEntry) (*Void, error)
	SetSessionOffline(context.Context, *SessionEntry) (*Void, error)
	GetUserOnlineSessions(context.Context, *Int32) (*SessionEntryList, error)
	GetUsersOnlineSessionsList(context.Context, *Int32List) (*UsersSessionEntryList, error)
}

RPCStatusServer is the server API for RPCStatus service.

type SessionEntry 

type SessionEntry struct {
	UserId               int32    `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ServerId             int32    `protobuf:"varint,2,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	AuthKeyId            int64    `protobuf:"varint,3,opt,name=auth_key_id,json=authKeyId,proto3" json:"auth_key_id,omitempty"`
	Expired              int64    `protobuf:"varint,4,opt,name=expired,proto3" json:"expired,omitempty"`
	Layer                int32    `protobuf:"varint,5,opt,name=layer,proto3" json:"layer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

//////////////////////////////////////////////////////////////////////////////////////

func (*SessionEntry) Descriptor 

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

func (*SessionEntry) GetAuthKeyId 

func (m *SessionEntry) GetAuthKeyId() int64

func (*SessionEntry) GetExpired 

func (m *SessionEntry) GetExpired() int64

func (*SessionEntry) GetLayer 

func (m *SessionEntry) GetLayer() int32

func (*SessionEntry) GetServerId 

func (m *SessionEntry) GetServerId() int32

func (*SessionEntry) GetUserId 

func (m *SessionEntry) GetUserId() int32

func (*SessionEntry) ProtoMessage 

func (*SessionEntry) ProtoMessage()

func (*SessionEntry) Reset 

func (m *SessionEntry) Reset()

func (*SessionEntry) String 

func (m *SessionEntry) String() string

func (*SessionEntry) XXX_DiscardUnknown 

func (m *SessionEntry) XXX_DiscardUnknown()

func (*SessionEntry) XXX_Marshal 

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

func (*SessionEntry) XXX_Merge 

func (dst *SessionEntry) XXX_Merge(src proto.Message)

func (*SessionEntry) XXX_Size 

func (m *SessionEntry) XXX_Size() int

func (*SessionEntry) XXX_Unmarshal 

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

type SessionEntryList 

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

func (*SessionEntryList) Descriptor 

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

func (*SessionEntryList) GetSessions 

func (m *SessionEntryList) GetSessions() []*SessionEntry

func (*SessionEntryList) ProtoMessage 

func (*SessionEntryList) ProtoMessage()

func (*SessionEntryList) Reset 

func (m *SessionEntryList) Reset()

func (*SessionEntryList) String 

func (m *SessionEntryList) String() string

func (*SessionEntryList) XXX_DiscardUnknown 

func (m *SessionEntryList) XXX_DiscardUnknown()

func (*SessionEntryList) XXX_Marshal 

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

func (*SessionEntryList) XXX_Merge 

func (dst *SessionEntryList) XXX_Merge(src proto.Message)

func (*SessionEntryList) XXX_Size 

func (m *SessionEntryList) XXX_Size() int

func (*SessionEntryList) XXX_Unmarshal 

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

type UsersSessionEntryList 

type UsersSessionEntryList struct {
	UsersSessions        map[int32]*SessionEntryList `` /* 189-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*UsersSessionEntryList) Descriptor 

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

func (*UsersSessionEntryList) GetUsersSessions 

func (m *UsersSessionEntryList) GetUsersSessions() map[int32]*SessionEntryList

func (*UsersSessionEntryList) ProtoMessage 

func (*UsersSessionEntryList) ProtoMessage()

func (*UsersSessionEntryList) Reset 

func (m *UsersSessionEntryList) Reset()

func (*UsersSessionEntryList) String 

func (m *UsersSessionEntryList) String() string

func (*UsersSessionEntryList) XXX_DiscardUnknown 

func (m *UsersSessionEntryList) XXX_DiscardUnknown()

func (*UsersSessionEntryList) XXX_Marshal 

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

func (*UsersSessionEntryList) XXX_Merge 

func (dst *UsersSessionEntryList) XXX_Merge(src proto.Message)

func (*UsersSessionEntryList) XXX_Size 

func (m *UsersSessionEntryList) XXX_Size() int

func (*UsersSessionEntryList) XXX_Unmarshal 

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

type Void 

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

func (*Void) Descriptor 

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

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) Reset 

func (m *Void) Reset()

func (*Void) String 

func (m *Void) String() string

func (*Void) XXX_DiscardUnknown 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal 

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

func (*Void) XXX_Merge 

func (dst *Void) XXX_Merge(src proto.Message)

func (*Void) XXX_Size 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal 

func (m *Void) 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.