v1

Documentation

Index

• Constants
• Variables
• func RegisterShareServer(s *grpc.Server, srv ShareServer)
• type AddShareReply
  • func (*AddShareReply) Descriptor() ([]byte, []int)
  • func (m *AddShareReply) GetShares() int64
  • func (m *AddShareReply) Marshal() (dAtA []byte, err error)
  • func (m *AddShareReply) MarshalTo(dAtA []byte) (int, error)
  • func (*AddShareReply) ProtoMessage()
  • func (m *AddShareReply) Reset()
  • func (m *AddShareReply) Size() (n int)
  • func (m *AddShareReply) String() string
  • func (m *AddShareReply) Unmarshal(dAtA []byte) error
• type AddShareRequest
  • func (*AddShareRequest) Descriptor() ([]byte, []int)
  • func (m *AddShareRequest) GetIp() string
  • func (m *AddShareRequest) GetMid() int64
  • func (m *AddShareRequest) GetOid() int64
  • func (m *AddShareRequest) GetType() int32
  • func (m *AddShareRequest) Marshal() (dAtA []byte, err error)
  • func (m *AddShareRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*AddShareRequest) ProtoMessage()
  • func (m *AddShareRequest) Reset()
  • func (m *AddShareRequest) Size() (n int)
  • func (m *AddShareRequest) String() string
  • func (m *AddShareRequest) Unmarshal(dAtA []byte) error
• type ShareClient
  • func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (ShareClient, error)
  • func NewShareClient(cc *grpc.ClientConn) ShareClient
• type ShareServer

Constants

const AppID = "main.appsvr.shareservice"

AppID discovery appid.

Variables

var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterShareServer

func RegisterShareServer(s *grpc.Server, srv ShareServer)

Types

type AddShareReply

type AddShareReply struct {
	Shares int64 `protobuf:"varint,1,opt,name=shares,proto3" json:"shares,omitempty"`
}

func (*AddShareReply) Descriptor

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

func (*AddShareReply) GetShares

func (m *AddShareReply) GetShares() int64

func (*AddShareReply) Marshal

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

func (*AddShareReply) MarshalTo

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

func (*AddShareReply) ProtoMessage

func (*AddShareReply) ProtoMessage()

func (*AddShareReply) Reset

func (m *AddShareReply) Reset()

func (*AddShareReply) Size

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

func (*AddShareReply) String

func (m *AddShareReply) String() string

func (*AddShareReply) Unmarshal

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

type AddShareRequest

type AddShareRequest struct {
	Oid  int64  `protobuf:"varint,1,opt,name=oid,proto3" json:"oid,omitempty"`
	Mid  int64  `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"`
	Type int32  `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
	Ip   string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
}

func (*AddShareRequest) Descriptor

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

func (*AddShareRequest) GetIp

func (m *AddShareRequest) GetIp() string

func (*AddShareRequest) GetMid

func (m *AddShareRequest) GetMid() int64

func (*AddShareRequest) GetOid

func (m *AddShareRequest) GetOid() int64

func (*AddShareRequest) GetType

func (m *AddShareRequest) GetType() int32

func (*AddShareRequest) Marshal

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

func (*AddShareRequest) MarshalTo

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

func (*AddShareRequest) ProtoMessage

func (*AddShareRequest) ProtoMessage()

func (*AddShareRequest) Reset

func (m *AddShareRequest) Reset()

func (*AddShareRequest) Size

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

func (*AddShareRequest) String

func (m *AddShareRequest) String() string

func (*AddShareRequest) Unmarshal

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

type ShareClient

type ShareClient interface {
	AddShare(ctx context.Context, in *AddShareRequest, opts ...grpc.CallOption) (*AddShareReply, error)
}

ShareClient is the client API for Share service.

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

func NewClient

func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (ShareClient, error)

NewClient new grpc client.

func NewShareClient

func NewShareClient(cc *grpc.ClientConn) ShareClient

type ShareServer

type ShareServer interface {
	AddShare(context.Context, *AddShareRequest) (*AddShareReply, error)
}

ShareServer is the server API for Share service.