coregrpc

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DVSRequestAPI_serviceDesc = _DVSRequestAPI_serviceDesc

Functions

func RegisterDVSRequestAPIServer 

func RegisterDVSRequestAPIServer(s grpc1.Server, srv DVSRequestAPIServer)

func StartGRPCServer 

func StartGRPCServer(env *core.Environment, ln net.Listener) error

Types

type Config 

type Config struct {
	MaxOpenConnections int
}

Config is an gRPC server configuration.

type DVSRequest 

type DVSRequest struct {
}

func (*DVSRequest) Descriptor 

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

func (*DVSRequest) Marshal 

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

func (*DVSRequest) MarshalTo 

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

func (*DVSRequest) MarshalToSizedBuffer 

func (m *DVSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DVSRequest) ProtoMessage 

func (*DVSRequest) ProtoMessage()

func (*DVSRequest) Reset 

func (m *DVSRequest) Reset()

func (*DVSRequest) Size 

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

func (*DVSRequest) String 

func (m *DVSRequest) String() string

func (*DVSRequest) Unmarshal 

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

func (*DVSRequest) XXX_DiscardUnknown 

func (m *DVSRequest) XXX_DiscardUnknown()

func (*DVSRequest) XXX_Marshal 

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

func (*DVSRequest) XXX_Merge 

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

func (*DVSRequest) XXX_Size 

func (m *DVSRequest) XXX_Size() int

func (*DVSRequest) XXX_Unmarshal 

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

type DVSRequestAPIClient 

type DVSRequestAPIClient interface {
	Ping(ctx context.Context, in *RequestPing, opts ...grpc.CallOption) (*ResponsePing, error)
	RequestDvsSync(ctx context.Context, in *DVSRequest, opts ...grpc.CallOption) (*ResultDvsRequestCommit, error)
	RequestDvsAsync(ctx context.Context, in *DVSRequest, opts ...grpc.CallOption) (*ResultRequestDvsAsync, error)
	QueryDvsRequest(ctx context.Context, in *QueryDvsRequestParam, opts ...grpc.CallOption) (*ResultDvsRequestCommit, error)
}

DVSRequestAPIClient is the client API for DVSRequestAPI service.

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

func NewDVSRequestAPIClient 

func NewDVSRequestAPIClient(cc grpc1.ClientConn) DVSRequestAPIClient

func StartGRPCClient 

func StartGRPCClient(protoAddr string) DVSRequestAPIClient

type DVSRequestAPIServer 

type DVSRequestAPIServer interface {
	Ping(context.Context, *RequestPing) (*ResponsePing, error)
	RequestDvsSync(context.Context, *DVSRequest) (*ResultDvsRequestCommit, error)
	RequestDvsAsync(context.Context, *DVSRequest) (*ResultRequestDvsAsync, error)
	QueryDvsRequest(context.Context, *QueryDvsRequestParam) (*ResultDvsRequestCommit, error)
}

DVSRequestAPIServer is the server API for DVSRequestAPI service.

type DVSRequestAPIServerAPI 

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

func (*DVSRequestAPIServerAPI) Ping 

func (api *DVSRequestAPIServerAPI) Ping(ctx context.Context, req *RequestPing) (*ResponsePing, error)

func (*DVSRequestAPIServerAPI) QueryDvsRequest 

func (api *DVSRequestAPIServerAPI) QueryDvsRequest(ctx context.Context, req *QueryDvsRequestParam) (*ResultDvsRequestCommit, error)

func (*DVSRequestAPIServerAPI) RequestDvsAsync 

func (api *DVSRequestAPIServerAPI) RequestDvsAsync(ctx context.Context, req *DVSRequest) (*ResultRequestDvsAsync, error)

func (*DVSRequestAPIServerAPI) RequestDvsSync 

func (api *DVSRequestAPIServerAPI) RequestDvsSync(ctx context.Context, req *DVSRequest) (*ResultDvsRequestCommit, error)

type QueryDvsRequestParam 

type QueryDvsRequestParam struct {
	Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

func (*QueryDvsRequestParam) Descriptor 

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

func (*QueryDvsRequestParam) GetHash 

func (m *QueryDvsRequestParam) GetHash() []byte

func (*QueryDvsRequestParam) Marshal 

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

func (*QueryDvsRequestParam) MarshalTo 

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

func (*QueryDvsRequestParam) MarshalToSizedBuffer 

func (m *QueryDvsRequestParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDvsRequestParam) ProtoMessage 

func (*QueryDvsRequestParam) ProtoMessage()

func (*QueryDvsRequestParam) Reset 

func (m *QueryDvsRequestParam) Reset()

func (*QueryDvsRequestParam) Size 

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

func (*QueryDvsRequestParam) String 

func (m *QueryDvsRequestParam) String() string

func (*QueryDvsRequestParam) Unmarshal 

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

func (*QueryDvsRequestParam) XXX_DiscardUnknown 

func (m *QueryDvsRequestParam) XXX_DiscardUnknown()

func (*QueryDvsRequestParam) XXX_Marshal 

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

func (*QueryDvsRequestParam) XXX_Merge 

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

func (*QueryDvsRequestParam) XXX_Size 

func (m *QueryDvsRequestParam) XXX_Size() int

func (*QueryDvsRequestParam) XXX_Unmarshal 

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

type RequestPing 

type RequestPing struct {
}

func (*RequestPing) Descriptor 

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

func (*RequestPing) Marshal 

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

func (*RequestPing) MarshalTo 

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

func (*RequestPing) MarshalToSizedBuffer 

func (m *RequestPing) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestPing) ProtoMessage 

func (*RequestPing) ProtoMessage()

func (*RequestPing) Reset 

func (m *RequestPing) Reset()

func (*RequestPing) Size 

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

func (*RequestPing) String 

func (m *RequestPing) String() string

func (*RequestPing) Unmarshal 

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

func (*RequestPing) XXX_DiscardUnknown 

func (m *RequestPing) XXX_DiscardUnknown()

func (*RequestPing) XXX_Marshal 

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

func (*RequestPing) XXX_Merge 

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

func (*RequestPing) XXX_Size 

func (m *RequestPing) XXX_Size() int

func (*RequestPing) XXX_Unmarshal 

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

type ResponseDVSRequest 

type ResponseDVSRequest struct {
}

SendDVSTask

func (*ResponseDVSRequest) Descriptor 

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

func (*ResponseDVSRequest) Marshal 

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

func (*ResponseDVSRequest) MarshalTo 

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

func (*ResponseDVSRequest) MarshalToSizedBuffer 

func (m *ResponseDVSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseDVSRequest) ProtoMessage 

func (*ResponseDVSRequest) ProtoMessage()

func (*ResponseDVSRequest) Reset 

func (m *ResponseDVSRequest) Reset()

func (*ResponseDVSRequest) Size 

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

func (*ResponseDVSRequest) String 

func (m *ResponseDVSRequest) String() string

func (*ResponseDVSRequest) Unmarshal 

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

func (*ResponseDVSRequest) XXX_DiscardUnknown 

func (m *ResponseDVSRequest) XXX_DiscardUnknown()

func (*ResponseDVSRequest) XXX_Marshal 

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

func (*ResponseDVSRequest) XXX_Merge 

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

func (*ResponseDVSRequest) XXX_Size 

func (m *ResponseDVSRequest) XXX_Size() int

func (*ResponseDVSRequest) XXX_Unmarshal 

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

type ResponsePing 

type ResponsePing struct {
}

---------------------------------------- Response types

func (*ResponsePing) Descriptor 

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

func (*ResponsePing) Marshal 

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

func (*ResponsePing) MarshalTo 

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

func (*ResponsePing) MarshalToSizedBuffer 

func (m *ResponsePing) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponsePing) ProtoMessage 

func (*ResponsePing) ProtoMessage()

func (*ResponsePing) Reset 

func (m *ResponsePing) Reset()

func (*ResponsePing) Size 

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

func (*ResponsePing) String 

func (m *ResponsePing) String() string

func (*ResponsePing) Unmarshal 

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

func (*ResponsePing) XXX_DiscardUnknown 

func (m *ResponsePing) XXX_DiscardUnknown()

func (*ResponsePing) XXX_Marshal 

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

func (*ResponsePing) XXX_Merge 

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

func (*ResponsePing) XXX_Size 

func (m *ResponsePing) XXX_Size() int

func (*ResponsePing) XXX_Unmarshal 

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

type ResultDvsRequestCommit 

type ResultDvsRequestCommit struct {
}

func (*ResultDvsRequestCommit) Descriptor 

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

func (*ResultDvsRequestCommit) Marshal 

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

func (*ResultDvsRequestCommit) MarshalTo 

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

func (*ResultDvsRequestCommit) MarshalToSizedBuffer 

func (m *ResultDvsRequestCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResultDvsRequestCommit) ProtoMessage 

func (*ResultDvsRequestCommit) ProtoMessage()

func (*ResultDvsRequestCommit) Reset 

func (m *ResultDvsRequestCommit) Reset()

func (*ResultDvsRequestCommit) Size 

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

func (*ResultDvsRequestCommit) String 

func (m *ResultDvsRequestCommit) String() string

func (*ResultDvsRequestCommit) Unmarshal 

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

func (*ResultDvsRequestCommit) XXX_DiscardUnknown 

func (m *ResultDvsRequestCommit) XXX_DiscardUnknown()

func (*ResultDvsRequestCommit) XXX_Marshal 

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

func (*ResultDvsRequestCommit) XXX_Merge 

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

func (*ResultDvsRequestCommit) XXX_Size 

func (m *ResultDvsRequestCommit) XXX_Size() int

func (*ResultDvsRequestCommit) XXX_Unmarshal 

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

type ResultRequestDvsAsync 

type ResultRequestDvsAsync struct {
}

func (*ResultRequestDvsAsync) Descriptor 

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

func (*ResultRequestDvsAsync) Marshal 

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

func (*ResultRequestDvsAsync) MarshalTo 

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

func (*ResultRequestDvsAsync) MarshalToSizedBuffer 

func (m *ResultRequestDvsAsync) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResultRequestDvsAsync) ProtoMessage 

func (*ResultRequestDvsAsync) ProtoMessage()

func (*ResultRequestDvsAsync) Reset 

func (m *ResultRequestDvsAsync) Reset()

func (*ResultRequestDvsAsync) Size 

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

func (*ResultRequestDvsAsync) String 

func (m *ResultRequestDvsAsync) String() string

func (*ResultRequestDvsAsync) Unmarshal 

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

func (*ResultRequestDvsAsync) XXX_DiscardUnknown 

func (m *ResultRequestDvsAsync) XXX_DiscardUnknown()

func (*ResultRequestDvsAsync) XXX_Marshal 

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

func (*ResultRequestDvsAsync) XXX_Merge 

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

func (*ResultRequestDvsAsync) XXX_Size 

func (m *ResultRequestDvsAsync) XXX_Size() int

func (*ResultRequestDvsAsync) XXX_Unmarshal 

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

type UnimplementedDVSRequestAPIServer 

type UnimplementedDVSRequestAPIServer struct {
}

UnimplementedDVSRequestAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedDVSRequestAPIServer) Ping 

func (*UnimplementedDVSRequestAPIServer) Ping(ctx context.Context, req *RequestPing) (*ResponsePing, error)

func (*UnimplementedDVSRequestAPIServer) QueryDvsRequest 

func (*UnimplementedDVSRequestAPIServer) QueryDvsRequest(ctx context.Context, req *QueryDvsRequestParam) (*ResultDvsRequestCommit, error)

func (*UnimplementedDVSRequestAPIServer) RequestDvsAsync 

func (*UnimplementedDVSRequestAPIServer) RequestDvsAsync(ctx context.Context, req *DVSRequest) (*ResultRequestDvsAsync, error)

func (*UnimplementedDVSRequestAPIServer) RequestDvsSync 

func (*UnimplementedDVSRequestAPIServer) RequestDvsSync(ctx context.Context, req *DVSRequest) (*ResultDvsRequestCommit, 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.