libra_gwapi_v1

Documentation

Index

• Variables
• func RegisterAccessServer(s *grpc.Server, srv AccessServer)
• func RegisterGatewayServer(s *grpc.Server, srv GatewayServer)
• type AccessClient
  • func NewAccessClient(cc grpc.ClientConnInterface) AccessClient
• type AccessServer
• type Access_SignInClient
• type Access_SignInServer
• type GatewayClient
  • func NewGatewayClient(cc grpc.ClientConnInterface) GatewayClient
• type GatewayServer
• type PushRequest
  • func (*PushRequest) Descriptor() ([]byte, []int)
  • func (x *PushRequest) GetData() *any.Any
  • func (x *PushRequest) GetRoleId() string
  • func (*PushRequest) ProtoMessage()
  • func (x *PushRequest) ProtoReflect() protoreflect.Message
  • func (x *PushRequest) Reset()
  • func (x *PushRequest) String() string
• type PushResponse
  • func (*PushResponse) Descriptor() ([]byte, []int)
  • func (*PushResponse) ProtoMessage()
  • func (x *PushResponse) ProtoReflect() protoreflect.Message
  • func (x *PushResponse) Reset()
  • func (x *PushResponse) String() string
• type SignInRequest
  • func (*SignInRequest) Descriptor() ([]byte, []int)
  • func (*SignInRequest) ProtoMessage()
  • func (x *SignInRequest) ProtoReflect() protoreflect.Message
  • func (x *SignInRequest) Reset()
  • func (x *SignInRequest) String() string
• type SubscribeRequest
  • func (*SubscribeRequest) Descriptor() ([]byte, []int)
  • func (*SubscribeRequest) ProtoMessage()
  • func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
  • func (x *SubscribeRequest) Reset()
  • func (x *SubscribeRequest) String() string
• type SubscribeResponse
  • func (*SubscribeResponse) Descriptor() ([]byte, []int)
  • func (*SubscribeResponse) ProtoMessage()
  • func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
  • func (x *SubscribeResponse) Reset()
  • func (x *SubscribeResponse) String() string
• type UnimplementedAccessServer
  • func (*UnimplementedAccessServer) SignIn(*SignInRequest, Access_SignInServer) error
• type UnimplementedGatewayServer
  • func (*UnimplementedGatewayServer) Push(context.Context, *PushRequest) (*PushResponse, error)
  • func (*UnimplementedGatewayServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

Variables

var File_gwapi_v1_access_proto protoreflect.FileDescriptor

var File_gwapi_v1_gateway_proto protoreflect.FileDescriptor

Functions

func RegisterAccessServer

func RegisterAccessServer(s *grpc.Server, srv AccessServer)

func RegisterGatewayServer

func RegisterGatewayServer(s *grpc.Server, srv GatewayServer)

Types

type AccessClient

type AccessClient interface {
	// Establish the push stream
	SignIn(ctx context.Context, in *SignInRequest, opts ...grpc.CallOption) (Access_SignInClient, error)
}

AccessClient is the client API for Access service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAccessClient

func NewAccessClient(cc grpc.ClientConnInterface) AccessClient

type AccessServer

type AccessServer interface {
	// Establish the push stream
	SignIn(*SignInRequest, Access_SignInServer) error
	// contains filtered or unexported methods
}

AccessServer is the server API for Access service. All implementations must embed UnimplementedAccessServer for forward compatibility

type Access_SignInClient

type Access_SignInClient interface {
	Recv() (*any.Any, error)
	grpc.ClientStream
}

type Access_SignInServer

type Access_SignInServer interface {
	Send(*any.Any) error
	grpc.ServerStream
}

type GatewayClient

type GatewayClient interface {
	// Push message to client
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
	// Subscribe a broadcast channel
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
}

GatewayClient is the client API for Gateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGatewayClient

func NewGatewayClient(cc grpc.ClientConnInterface) GatewayClient

type GatewayServer

type GatewayServer interface {
	// Push message to client
	Push(context.Context, *PushRequest) (*PushResponse, error)
	// Subscribe a broadcast channel
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	// contains filtered or unexported methods
}

GatewayServer is the server API for Gateway service. All implementations must embed UnimplementedGatewayServer for forward compatibility

type PushRequest

type PushRequest struct {
	RoleId string   `protobuf:"bytes,1,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	Data   *any.Any `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PushRequest) Descriptor

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

Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.

func (*PushRequest) GetData

func (x *PushRequest) GetData() *any.Any

func (*PushRequest) GetRoleId

func (x *PushRequest) GetRoleId() string

func (*PushRequest) ProtoMessage

func (*PushRequest) ProtoMessage()

func (*PushRequest) ProtoReflect

func (x *PushRequest) ProtoReflect() protoreflect.Message

func (*PushRequest) Reset

func (x *PushRequest) Reset()

func (*PushRequest) String

func (x *PushRequest) String() string

type PushResponse

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

func (*PushResponse) Descriptor

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

Deprecated: Use PushResponse.ProtoReflect.Descriptor instead.

func (*PushResponse) ProtoMessage

func (*PushResponse) ProtoMessage()

func (*PushResponse) ProtoReflect

func (x *PushResponse) ProtoReflect() protoreflect.Message

func (*PushResponse) Reset

func (x *PushResponse) Reset()

func (*PushResponse) String

func (x *PushResponse) String() string

type SignInRequest

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

func (*SignInRequest) Descriptor

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

Deprecated: Use SignInRequest.ProtoReflect.Descriptor instead.

func (*SignInRequest) ProtoMessage

func (*SignInRequest) ProtoMessage()

func (*SignInRequest) ProtoReflect

func (x *SignInRequest) ProtoReflect() protoreflect.Message

func (*SignInRequest) Reset

func (x *SignInRequest) Reset()

func (*SignInRequest) String

func (x *SignInRequest) String() string

type SubscribeRequest

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

func (*SubscribeRequest) Descriptor

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect

func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeRequest) Reset

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String

func (x *SubscribeRequest) String() string

type SubscribeResponse

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

func (*SubscribeResponse) Descriptor

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) ProtoMessage

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect

func (x *SubscribeResponse) ProtoReflect() protoreflect.Message

func (*SubscribeResponse) Reset

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String

func (x *SubscribeResponse) String() string

type UnimplementedAccessServer

type UnimplementedAccessServer struct {
}

UnimplementedAccessServer must be embedded to have forward compatible implementations.

func (*UnimplementedAccessServer) SignIn

func (*UnimplementedAccessServer) SignIn(*SignInRequest, Access_SignInServer) error

type UnimplementedGatewayServer

type UnimplementedGatewayServer struct {
}

UnimplementedGatewayServer must be embedded to have forward compatible implementations.

func (*UnimplementedGatewayServer) Push

func (*UnimplementedGatewayServer) Push(context.Context, *PushRequest) (*PushResponse, error)

func (*UnimplementedGatewayServer) Subscribe

func (*UnimplementedGatewayServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)