v1

package
v0.0.0-...-83adff0 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const AppID = "manager.service.open"

AppID unique app id for service discovery

Variables

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

Functions

func RegisterOpenServer 

func RegisterOpenServer(s *grpc.Server, srv OpenServer)

Types

type AppIDReply 

type AppIDReply struct {
	AppId                int64    `protobuf:"varint,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AppIDReply) Descriptor 

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

func (*AppIDReply) GetAppId 

func (m *AppIDReply) GetAppId() int64

func (*AppIDReply) Marshal 

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

func (*AppIDReply) MarshalTo 

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

func (*AppIDReply) ProtoMessage 

func (*AppIDReply) ProtoMessage()

func (*AppIDReply) Reset 

func (m *AppIDReply) Reset()

func (*AppIDReply) Size 

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

func (*AppIDReply) String 

func (m *AppIDReply) String() string

func (*AppIDReply) Unmarshal 

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

func (*AppIDReply) XXX_DiscardUnknown 

func (m *AppIDReply) XXX_DiscardUnknown()

func (*AppIDReply) XXX_Marshal 

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

func (*AppIDReply) XXX_Merge 

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

func (*AppIDReply) XXX_Size 

func (m *AppIDReply) XXX_Size() int

func (*AppIDReply) XXX_Unmarshal 

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

type AppIDReq 

type AppIDReq struct {
	AppKey               string   `protobuf:"bytes,2,opt,name=app_key,json=appKey,proto3" json:"app_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AppIDReq) Descriptor 

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

func (*AppIDReq) GetAppKey 

func (m *AppIDReq) GetAppKey() string

func (*AppIDReq) Marshal 

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

func (*AppIDReq) MarshalTo 

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

func (*AppIDReq) ProtoMessage 

func (*AppIDReq) ProtoMessage()

func (*AppIDReq) Reset 

func (m *AppIDReq) Reset()

func (*AppIDReq) Size 

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

func (*AppIDReq) String 

func (m *AppIDReq) String() string

func (*AppIDReq) Unmarshal 

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

func (*AppIDReq) XXX_DiscardUnknown 

func (m *AppIDReq) XXX_DiscardUnknown()

func (*AppIDReq) XXX_Marshal 

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

func (*AppIDReq) XXX_Merge 

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

func (*AppIDReq) XXX_Size 

func (m *AppIDReq) XXX_Size() int

func (*AppIDReq) XXX_Unmarshal 

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

type CloseReply 

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

func (*CloseReply) Descriptor 

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

func (*CloseReply) Marshal 

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

func (*CloseReply) MarshalTo 

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

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) Reset 

func (m *CloseReply) Reset()

func (*CloseReply) Size 

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

func (*CloseReply) String 

func (m *CloseReply) String() string

func (*CloseReply) Unmarshal 

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

func (*CloseReply) XXX_DiscardUnknown 

func (m *CloseReply) XXX_DiscardUnknown()

func (*CloseReply) XXX_Marshal 

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

func (*CloseReply) XXX_Merge 

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

func (*CloseReply) XXX_Size 

func (m *CloseReply) XXX_Size() int

func (*CloseReply) XXX_Unmarshal 

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

type CloseReq 

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

func (*CloseReq) Descriptor 

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

func (*CloseReq) Marshal 

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

func (*CloseReq) MarshalTo 

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

func (*CloseReq) ProtoMessage 

func (*CloseReq) ProtoMessage()

func (*CloseReq) Reset 

func (m *CloseReq) Reset()

func (*CloseReq) Size 

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

func (*CloseReq) String 

func (m *CloseReq) String() string

func (*CloseReq) Unmarshal 

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

func (*CloseReq) XXX_DiscardUnknown 

func (m *CloseReq) XXX_DiscardUnknown()

func (*CloseReq) XXX_Marshal 

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

func (*CloseReq) XXX_Merge 

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

func (*CloseReq) XXX_Size 

func (m *CloseReq) XXX_Size() int

func (*CloseReq) XXX_Unmarshal 

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

type OpenClient 

type OpenClient interface {
	// Ping check dao health.
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error)
	// Close close all dao.
	Close(ctx context.Context, in *CloseReq, opts ...grpc.CallOption) (*CloseReply, error)
	// Secret .
	Secret(ctx context.Context, in *SecretReq, opts ...grpc.CallOption) (*SecretReply, error)
	// AppID .
	AppID(ctx context.Context, in *AppIDReq, opts ...grpc.CallOption) (*AppIDReply, error)
}

OpenClient is the client API for Open 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) (OpenClient, error)

NewClient new member grpc client

func NewOpenClient 

func NewOpenClient(cc *grpc.ClientConn) OpenClient

type OpenServer 

type OpenServer interface {
	// Ping check dao health.
	Ping(context.Context, *PingReq) (*PingReply, error)
	// Close close all dao.
	Close(context.Context, *CloseReq) (*CloseReply, error)
	// Secret .
	Secret(context.Context, *SecretReq) (*SecretReply, error)
	// AppID .
	AppID(context.Context, *AppIDReq) (*AppIDReply, error)
}

OpenServer is the server API for Open service.

type PingReply 

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

func (*PingReply) Descriptor 

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

func (*PingReply) Marshal 

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

func (*PingReply) MarshalTo 

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

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) Reset 

func (m *PingReply) Reset()

func (*PingReply) Size 

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

func (*PingReply) String 

func (m *PingReply) String() string

func (*PingReply) Unmarshal 

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

func (*PingReply) XXX_DiscardUnknown 

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal 

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

func (*PingReply) XXX_Merge 

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

func (*PingReply) XXX_Size 

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal 

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

type PingReq 

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

func (*PingReq) Descriptor 

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

func (*PingReq) Marshal 

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

func (*PingReq) MarshalTo 

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

func (*PingReq) ProtoMessage 

func (*PingReq) ProtoMessage()

func (*PingReq) Reset 

func (m *PingReq) Reset()

func (*PingReq) Size 

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

func (*PingReq) String 

func (m *PingReq) String() string

func (*PingReq) Unmarshal 

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

func (*PingReq) XXX_DiscardUnknown 

func (m *PingReq) XXX_DiscardUnknown()

func (*PingReq) XXX_Marshal 

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

func (*PingReq) XXX_Merge 

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

func (*PingReq) XXX_Size 

func (m *PingReq) XXX_Size() int

func (*PingReq) XXX_Unmarshal 

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

type SecretReply 

type SecretReply struct {
	Res                  string   `protobuf:"bytes,1,opt,name=res,proto3" json:"res,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SecretReply) Descriptor 

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

func (*SecretReply) GetRes 

func (m *SecretReply) GetRes() string

func (*SecretReply) Marshal 

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

func (*SecretReply) MarshalTo 

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

func (*SecretReply) ProtoMessage 

func (*SecretReply) ProtoMessage()

func (*SecretReply) Reset 

func (m *SecretReply) Reset()

func (*SecretReply) Size 

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

func (*SecretReply) String 

func (m *SecretReply) String() string

func (*SecretReply) Unmarshal 

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

func (*SecretReply) XXX_DiscardUnknown 

func (m *SecretReply) XXX_DiscardUnknown()

func (*SecretReply) XXX_Marshal 

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

func (*SecretReply) XXX_Merge 

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

func (*SecretReply) XXX_Size 

func (m *SecretReply) XXX_Size() int

func (*SecretReply) XXX_Unmarshal 

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

type SecretReq 

type SecretReq struct {
	SappKey              string   `protobuf:"bytes,2,opt,name=sapp_key,json=sappKey,proto3" json:"sapp_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SecretReq) Descriptor 

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

func (*SecretReq) GetSappKey 

func (m *SecretReq) GetSappKey() string

func (*SecretReq) Marshal 

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

func (*SecretReq) MarshalTo 

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

func (*SecretReq) ProtoMessage 

func (*SecretReq) ProtoMessage()

func (*SecretReq) Reset 

func (m *SecretReq) Reset()

func (*SecretReq) Size 

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

func (*SecretReq) String 

func (m *SecretReq) String() string

func (*SecretReq) Unmarshal 

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

func (*SecretReq) XXX_DiscardUnknown 

func (m *SecretReq) XXX_DiscardUnknown()

func (*SecretReq) XXX_Marshal 

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

func (*SecretReq) XXX_Merge 

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

func (*SecretReq) XXX_Size 

func (m *SecretReq) XXX_Size() int

func (*SecretReq) XXX_Unmarshal 

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