rpc

Documentation

Index

• func RegisterTokenServer(s *grpc.Server, srv TokenServer)
• type CleanupResult
  • func (*CleanupResult) Descriptor() ([]byte, []int)
  • func (m *CleanupResult) GetNumDeleteToken() int64
  • func (*CleanupResult) ProtoMessage()
  • func (m *CleanupResult) Reset()
  • func (m *CleanupResult) String() string
  • func (m *CleanupResult) XXX_DiscardUnknown()
  • func (m *CleanupResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CleanupResult) XXX_Merge(src proto.Message)
  • func (m *CleanupResult) XXX_Size() int
  • func (m *CleanupResult) XXX_Unmarshal(b []byte) error
• type Token
  • func (*Token) Descriptor() ([]byte, []int)
  • func (m *Token) GetEmail() string
  • func (m *Token) GetMeta() []byte
  • func (m *Token) GetPurpose() string
  • func (m *Token) GetToken() string
  • func (*Token) ProtoMessage()
  • func (m *Token) Reset()
  • func (m *Token) String() string
  • func (m *Token) XXX_DiscardUnknown()
  • func (m *Token) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Token) XXX_Merge(src proto.Message)
  • func (m *Token) XXX_Size() int
  • func (m *Token) XXX_Unmarshal(b []byte) error
• type TokenClient
  • func NewTokenClient(cc *grpc.ClientConn) TokenClient
• type TokenServer
• type UnimplementedTokenServer
  • func (*UnimplementedTokenServer) Pop(ctx context.Context, req *Token) (*Token, error)
  • func (*UnimplementedTokenServer) Push(ctx context.Context, req *Token) (*Token, error)

Functions

func RegisterTokenServer

func RegisterTokenServer(s *grpc.Server, srv TokenServer)

Types

type CleanupResult

type CleanupResult struct {
	NumDeleteToken       int64    `protobuf:"varint,1,opt,name=num_delete_token,json=numDeleteToken,proto3" json:"num_delete_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CleanupResult) Descriptor

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

func (*CleanupResult) GetNumDeleteToken

func (m *CleanupResult) GetNumDeleteToken() int64

func (*CleanupResult) ProtoMessage

func (*CleanupResult) ProtoMessage()

func (*CleanupResult) Reset

func (m *CleanupResult) Reset()

func (*CleanupResult) String

func (m *CleanupResult) String() string

func (*CleanupResult) XXX_DiscardUnknown

func (m *CleanupResult) XXX_DiscardUnknown()

func (*CleanupResult) XXX_Marshal

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

func (*CleanupResult) XXX_Merge

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

func (*CleanupResult) XXX_Size

func (m *CleanupResult) XXX_Size() int

func (*CleanupResult) XXX_Unmarshal

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

type Token

type Token struct {
	Email                string   `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Purpose              string   `protobuf:"bytes,3,opt,name=purpose,proto3" json:"purpose,omitempty"`
	Meta                 []byte   `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Token) Descriptor

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

func (*Token) GetEmail

func (m *Token) GetEmail() string

func (*Token) GetMeta

func (m *Token) GetMeta() []byte

func (*Token) GetPurpose

func (m *Token) GetPurpose() string

func (*Token) GetToken

func (m *Token) GetToken() string

func (*Token) ProtoMessage

func (*Token) ProtoMessage()

func (*Token) Reset

func (m *Token) Reset()

func (*Token) String

func (m *Token) String() string

func (*Token) XXX_DiscardUnknown

func (m *Token) XXX_DiscardUnknown()

func (*Token) XXX_Marshal

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

func (*Token) XXX_Merge

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

func (*Token) XXX_Size

func (m *Token) XXX_Size() int

func (*Token) XXX_Unmarshal

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

type TokenClient

type TokenClient interface {
	Push(ctx context.Context, in *Token, opts ...grpc.CallOption) (*Token, error)
	Pop(ctx context.Context, in *Token, opts ...grpc.CallOption) (*Token, error)
}

TokenClient is the client API for Token service.

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

func NewTokenClient

func NewTokenClient(cc *grpc.ClientConn) TokenClient

type TokenServer

type TokenServer interface {
	Push(context.Context, *Token) (*Token, error)
	Pop(context.Context, *Token) (*Token, error)
}

TokenServer is the server API for Token service.

type UnimplementedTokenServer

type UnimplementedTokenServer struct {
}

UnimplementedTokenServer can be embedded to have forward compatible implementations.

func (*UnimplementedTokenServer) Pop

func (*UnimplementedTokenServer) Pop(ctx context.Context, req *Token) (*Token, error)

func (*UnimplementedTokenServer) Push

func (*UnimplementedTokenServer) Push(ctx context.Context, req *Token) (*Token, error)