client

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2020 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthClient = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClient   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterWsHostServer 

func RegisterWsHostServer(s *grpc.Server, srv WsHostServer)

Types

type LoginPB 

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

func (*LoginPB) Descriptor 

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

func (*LoginPB) Marshal 

func (m *LoginPB) Marshal() (dAtA []byte, err error)

func (*LoginPB) MarshalTo 

func (m *LoginPB) MarshalTo(dAtA []byte) (int, error)

func (*LoginPB) ProtoMessage 

func (*LoginPB) ProtoMessage()

func (*LoginPB) Reset 

func (m *LoginPB) Reset()

func (*LoginPB) Size 

func (m *LoginPB) Size() (n int)

func (*LoginPB) String 

func (m *LoginPB) String() string

func (*LoginPB) Unmarshal 

func (m *LoginPB) Unmarshal(dAtA []byte) error

func (*LoginPB) XXX_DiscardUnknown 

func (m *LoginPB) XXX_DiscardUnknown()

func (*LoginPB) XXX_Marshal 

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

func (*LoginPB) XXX_Merge 

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

func (*LoginPB) XXX_Size 

func (m *LoginPB) XXX_Size() int

func (*LoginPB) XXX_Unmarshal 

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

type MemberSeat 

type MemberSeat struct {
	SeatID               []byte              `protobuf:"bytes,1,opt,name=seatID,proto3" json:"seatID,omitempty"`
	MemberEpoch          *pdi.MemberEpoch    `protobuf:"bytes,10,opt,name=member_epoch,json=memberEpoch,proto3" json:"member_epoch,omitempty"`
	RepoSeed             *repo.RepoSeed      `protobuf:"bytes,11,opt,name=repo_seed,json=repoSeed,proto3" json:"repo_seed,omitempty"`
	GenesisSeed          *repo.GenesisSeed   `protobuf:"bytes,12,opt,name=genesis_seed,json=genesisSeed,proto3" json:"genesis_seed,omitempty"`
	Services             []*plan.ServiceInfo `protobuf:"bytes,13,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*MemberSeat) Descriptor 

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

func (*MemberSeat) GetGenesisSeed 

func (m *MemberSeat) GetGenesisSeed() *repo.GenesisSeed

func (*MemberSeat) GetMemberEpoch 

func (m *MemberSeat) GetMemberEpoch() *pdi.MemberEpoch

func (*MemberSeat) GetRepoSeed 

func (m *MemberSeat) GetRepoSeed() *repo.RepoSeed

func (*MemberSeat) GetSeatID 

func (m *MemberSeat) GetSeatID() []byte

func (*MemberSeat) GetServices 

func (m *MemberSeat) GetServices() []*plan.ServiceInfo

func (*MemberSeat) Marshal 

func (m *MemberSeat) Marshal() (dAtA []byte, err error)

func (*MemberSeat) MarshalTo 

func (m *MemberSeat) MarshalTo(dAtA []byte) (int, error)

func (*MemberSeat) ProtoMessage 

func (*MemberSeat) ProtoMessage()

func (*MemberSeat) Reset 

func (m *MemberSeat) Reset()

func (*MemberSeat) SeatDesc added in v0.0.2 

func (seat *MemberSeat) SeatDesc() string

SeatDesc returns a string containing useful info about this MemberSeat

func (*MemberSeat) Size 

func (m *MemberSeat) Size() (n int)

func (*MemberSeat) String 

func (m *MemberSeat) String() string

func (*MemberSeat) Unmarshal 

func (m *MemberSeat) Unmarshal(dAtA []byte) error

func (*MemberSeat) XXX_DiscardUnknown 

func (m *MemberSeat) XXX_DiscardUnknown()

func (*MemberSeat) XXX_Marshal 

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

func (*MemberSeat) XXX_Merge 

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

func (*MemberSeat) XXX_Size 

func (m *MemberSeat) XXX_Size() int

func (*MemberSeat) XXX_Unmarshal 

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

type MemberSeatReq 

type MemberSeatReq struct {
	MemberSeed           *repo.MemberSeed `protobuf:"bytes,1,opt,name=member_seed,json=memberSeed,proto3" json:"member_seed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*MemberSeatReq) Descriptor 

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

func (*MemberSeatReq) GetMemberSeed 

func (m *MemberSeatReq) GetMemberSeed() *repo.MemberSeed

func (*MemberSeatReq) Marshal 

func (m *MemberSeatReq) Marshal() (dAtA []byte, err error)

func (*MemberSeatReq) MarshalTo 

func (m *MemberSeatReq) MarshalTo(dAtA []byte) (int, error)

func (*MemberSeatReq) ProtoMessage 

func (*MemberSeatReq) ProtoMessage()

func (*MemberSeatReq) Reset 

func (m *MemberSeatReq) Reset()

func (*MemberSeatReq) Size 

func (m *MemberSeatReq) Size() (n int)

func (*MemberSeatReq) String 

func (m *MemberSeatReq) String() string

func (*MemberSeatReq) Unmarshal 

func (m *MemberSeatReq) Unmarshal(dAtA []byte) error

func (*MemberSeatReq) XXX_DiscardUnknown 

func (m *MemberSeatReq) XXX_DiscardUnknown()

func (*MemberSeatReq) XXX_Marshal 

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

func (*MemberSeatReq) XXX_Merge 

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

func (*MemberSeatReq) XXX_Size 

func (m *MemberSeatReq) XXX_Size() int

func (*MemberSeatReq) XXX_Unmarshal 

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

type SeatInfo 

type SeatInfo struct {
	Seed                 *repo.MemberSeed  `protobuf:"bytes,1,opt,name=seed,proto3" json:"seed,omitempty"`
	Seat                 *MemberSeat       `protobuf:"bytes,2,opt,name=seat,proto3" json:"seat,omitempty"`
	Host                 *plan.ServiceInfo `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SeatInfo) Descriptor 

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

func (*SeatInfo) GetHost 

func (m *SeatInfo) GetHost() *plan.ServiceInfo

func (*SeatInfo) GetSeat 

func (m *SeatInfo) GetSeat() *MemberSeat

func (*SeatInfo) GetSeed 

func (m *SeatInfo) GetSeed() *repo.MemberSeed

func (*SeatInfo) Marshal 

func (m *SeatInfo) Marshal() (dAtA []byte, err error)

func (*SeatInfo) MarshalTo 

func (m *SeatInfo) MarshalTo(dAtA []byte) (int, error)

func (*SeatInfo) ProtoMessage 

func (*SeatInfo) ProtoMessage()

func (*SeatInfo) Reset 

func (m *SeatInfo) Reset()

func (*SeatInfo) Size 

func (m *SeatInfo) Size() (n int)

func (*SeatInfo) String 

func (m *SeatInfo) String() string

func (*SeatInfo) Unmarshal 

func (m *SeatInfo) Unmarshal(dAtA []byte) error

func (*SeatInfo) XXX_DiscardUnknown 

func (m *SeatInfo) XXX_DiscardUnknown()

func (*SeatInfo) XXX_Marshal 

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

func (*SeatInfo) XXX_Merge 

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

func (*SeatInfo) XXX_Size 

func (m *SeatInfo) XXX_Size() int

func (*SeatInfo) XXX_Unmarshal 

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

type SessionPB 

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

func (*SessionPB) Descriptor 

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

func (*SessionPB) Marshal 

func (m *SessionPB) Marshal() (dAtA []byte, err error)

func (*SessionPB) MarshalTo 

func (m *SessionPB) MarshalTo(dAtA []byte) (int, error)

func (*SessionPB) ProtoMessage 

func (*SessionPB) ProtoMessage()

func (*SessionPB) Reset 

func (m *SessionPB) Reset()

func (*SessionPB) Size 

func (m *SessionPB) Size() (n int)

func (*SessionPB) String 

func (m *SessionPB) String() string

func (*SessionPB) Unmarshal 

func (m *SessionPB) Unmarshal(dAtA []byte) error

func (*SessionPB) XXX_DiscardUnknown 

func (m *SessionPB) XXX_DiscardUnknown()

func (*SessionPB) XXX_Marshal 

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

func (*SessionPB) XXX_Merge 

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

func (*SessionPB) XXX_Size 

func (m *SessionPB) XXX_Size() int

func (*SessionPB) XXX_Unmarshal 

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

type UnimplementedWsHostServer 

type UnimplementedWsHostServer struct {
}

UnimplementedWsHostServer can be embedded to have forward compatible implementations.

func (*UnimplementedWsHostServer) CreateNewSeat 

func (*UnimplementedWsHostServer) CreateNewSeat(ctx context.Context, req *MemberSeatReq) (*MemberSeat, error)

func (*UnimplementedWsHostServer) OpenWsSession 

func (*UnimplementedWsHostServer) OpenWsSession(srv WsHost_OpenWsSessionServer) error

type WsHostClient 

type WsHostClient interface {
	CreateNewSeat(ctx context.Context, in *MemberSeatReq, opts ...grpc.CallOption) (*MemberSeat, error)
	// Opens a new member session.
	OpenWsSession(ctx context.Context, opts ...grpc.CallOption) (WsHost_OpenWsSessionClient, error)
}

WsHostClient is the client API for WsHost service.

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

func NewWsHostClient 

func NewWsHostClient(cc *grpc.ClientConn) WsHostClient

type WsHostServer 

type WsHostServer interface {
	CreateNewSeat(context.Context, *MemberSeatReq) (*MemberSeat, error)
	// Opens a new member session.
	OpenWsSession(WsHost_OpenWsSessionServer) error
}

WsHostServer is the server API for WsHost service.

type WsHost_OpenWsSessionClient 

type WsHost_OpenWsSessionClient interface {
	Send(*repo.Msg) error
	Recv() (*repo.Msg, error)
	grpc.ClientStream
}

type WsHost_OpenWsSessionServer 

type WsHost_OpenWsSessionServer interface {
	Send(*repo.Msg) error
	Recv() (*repo.Msg, error)
	grpc.ServerStream
}

type WsLogin 

type WsLogin struct {
	// Rhe workstation seat ID that was issued via WsService.CreateNewSeat().
	SeatID []byte `protobuf:"bytes,1,opt,name=seatID,proto3" json:"seatID,omitempty"`
	// Used to decrypt the key hive within the given seat.
	Pass                 []byte   `protobuf:"bytes,2,opt,name=pass,proto3" json:"pass,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WsLogin) Descriptor 

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

func (*WsLogin) GetPass 

func (m *WsLogin) GetPass() []byte

func (*WsLogin) GetSeatID 

func (m *WsLogin) GetSeatID() []byte

func (*WsLogin) Marshal 

func (m *WsLogin) Marshal() (dAtA []byte, err error)

func (*WsLogin) MarshalTo 

func (m *WsLogin) MarshalTo(dAtA []byte) (int, error)

func (*WsLogin) ProtoMessage 

func (*WsLogin) ProtoMessage()

func (*WsLogin) Reset 

func (m *WsLogin) Reset()

func (*WsLogin) Size 

func (m *WsLogin) Size() (n int)

func (*WsLogin) String 

func (m *WsLogin) String() string

func (*WsLogin) Unmarshal 

func (m *WsLogin) Unmarshal(dAtA []byte) error

func (*WsLogin) XXX_DiscardUnknown 

func (m *WsLogin) XXX_DiscardUnknown()

func (*WsLogin) XXX_Marshal 

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

func (*WsLogin) XXX_Merge 

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

func (*WsLogin) XXX_Size 

func (m *WsLogin) XXX_Size() int

func (*WsLogin) XXX_Unmarshal 

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