integration

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

README

package integration

import "storj.io/drpc/internal/integration"

Usage

type DRPCServiceClient
type DRPCServiceClient interface {
	DRPCConn() drpc.Conn

	Method1(ctx context.Context, in *In) (*Out, error)
	Method2(ctx context.Context) (DRPCService_Method2Client, error)
	Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error)
	Method4(ctx context.Context) (DRPCService_Method4Client, error)
}
func NewDRPCServiceClient
func NewDRPCServiceClient(cc drpc.Conn) DRPCServiceClient
type DRPCServiceDescription
type DRPCServiceDescription struct{}
func (DRPCServiceDescription) Method
func (DRPCServiceDescription) Method(n int) (string, drpc.Handler, interface{}, bool)
func (DRPCServiceDescription) NumMethods
func (DRPCServiceDescription) NumMethods() int
type DRPCServiceServer
type DRPCServiceServer interface {
	DRPCMethod1(context.Context, *In) (*Out, error)
	DRPCMethod2(DRPCService_Method2Stream) error
	DRPCMethod3(*In, DRPCService_Method3Stream) error
	DRPCMethod4(DRPCService_Method4Stream) error
}
type DRPCService_Method1Stream
type DRPCService_Method1Stream interface {
	drpc.Stream
	SendAndClose(*Out) error
}
type DRPCService_Method2Client
type DRPCService_Method2Client interface {
	drpc.Stream
	Send(*In) error
	CloseAndRecv() (*Out, error)
}
type DRPCService_Method2Stream
type DRPCService_Method2Stream interface {
	drpc.Stream
	SendAndClose(*Out) error
	Recv() (*In, error)
}
type DRPCService_Method3Client
type DRPCService_Method3Client interface {
	drpc.Stream
	Recv() (*Out, error)
}
type DRPCService_Method3Stream
type DRPCService_Method3Stream interface {
	drpc.Stream
	Send(*Out) error
}
type DRPCService_Method4Client
type DRPCService_Method4Client interface {
	drpc.Stream
	Send(*In) error
	Recv() (*Out, error)
}
type DRPCService_Method4Stream
type DRPCService_Method4Stream interface {
	drpc.Stream
	Send(*Out) error
	Recv() (*In, error)
}
type In
type In struct {
	In                   int64    `protobuf:"varint,1,opt,name=in,proto3" json:"in,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
func (*In) Descriptor
func (*In) Descriptor() ([]byte, []int)
func (*In) GetIn
func (m *In) GetIn() int64
func (*In) ProtoMessage
func (*In) ProtoMessage()
func (*In) Reset
func (m *In) Reset()
func (*In) String
func (m *In) String() string
func (*In) XXX_DiscardUnknown
func (m *In) XXX_DiscardUnknown()
func (*In) XXX_Marshal
func (m *In) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*In) XXX_Merge
func (m *In) XXX_Merge(src proto.Message)
func (*In) XXX_Size
func (m *In) XXX_Size() int
func (*In) XXX_Unmarshal
func (m *In) XXX_Unmarshal(b []byte) error
type Out
type Out struct {
	Out                  int64    `protobuf:"varint,1,opt,name=out,proto3" json:"out,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
func (*Out) Descriptor
func (*Out) Descriptor() ([]byte, []int)
func (*Out) GetOut
func (m *Out) GetOut() int64
func (*Out) ProtoMessage
func (*Out) ProtoMessage()
func (*Out) Reset
func (m *Out) Reset()
func (*Out) String
func (m *Out) String() string
func (*Out) XXX_DiscardUnknown
func (m *Out) XXX_DiscardUnknown()
func (*Out) XXX_Marshal
func (m *Out) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Out) XXX_Merge
func (m *Out) XXX_Merge(src proto.Message)
func (*Out) XXX_Size
func (m *Out) XXX_Size() int
func (*Out) XXX_Unmarshal
func (m *Out) XXX_Unmarshal(b []byte) error

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DRPCRegisterService added in v0.0.3 

func DRPCRegisterService(srv drpc.Server, impl DRPCServiceServer)

Types

type DRPCServiceClient 

type DRPCServiceClient interface {
	DRPCConn() drpc.Conn

	Method1(ctx context.Context, in *In) (*Out, error)
	Method2(ctx context.Context) (DRPCService_Method2Client, error)
	Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error)
	Method4(ctx context.Context) (DRPCService_Method4Client, error)
}

func NewDRPCServiceClient 

func NewDRPCServiceClient(cc drpc.Conn) DRPCServiceClient

type DRPCServiceDescription 

type DRPCServiceDescription struct{}

func (DRPCServiceDescription) Method 

func (DRPCServiceDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

func (DRPCServiceDescription) NumMethods 

func (DRPCServiceDescription) NumMethods() int

type DRPCServiceServer 

type DRPCServiceServer interface {
	Method1(context.Context, *In) (*Out, error)
	Method2(DRPCService_Method2Stream) error
	Method3(*In, DRPCService_Method3Stream) error
	Method4(DRPCService_Method4Stream) error
}

type DRPCService_Method1Stream 

type DRPCService_Method1Stream interface {
	drpc.Stream
	SendAndClose(*Out) error
}

type DRPCService_Method2Client 

type DRPCService_Method2Client interface {
	drpc.Stream
	Send(*In) error
	CloseAndRecv() (*Out, error)
}

type DRPCService_Method2Stream 

type DRPCService_Method2Stream interface {
	drpc.Stream
	SendAndClose(*Out) error
	Recv() (*In, error)
}

type DRPCService_Method3Client 

type DRPCService_Method3Client interface {
	drpc.Stream
	Recv() (*Out, error)
}

type DRPCService_Method3Stream 

type DRPCService_Method3Stream interface {
	drpc.Stream
	Send(*Out) error
}

type DRPCService_Method4Client 

type DRPCService_Method4Client interface {
	drpc.Stream
	Send(*In) error
	Recv() (*Out, error)
}

type DRPCService_Method4Stream 

type DRPCService_Method4Stream interface {
	drpc.Stream
	Send(*Out) error
	Recv() (*In, error)
}

type In 

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

func (*In) Descriptor 

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

func (*In) GetIn 

func (m *In) GetIn() int64

func (*In) ProtoMessage 

func (*In) ProtoMessage()

func (*In) Reset 

func (m *In) Reset()

func (*In) String 

func (m *In) String() string

func (*In) XXX_DiscardUnknown 

func (m *In) XXX_DiscardUnknown()

func (*In) XXX_Marshal 

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

func (*In) XXX_Merge 

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

func (*In) XXX_Size 

func (m *In) XXX_Size() int

func (*In) XXX_Unmarshal 

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

type Out 

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

func (*Out) Descriptor 

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

func (*Out) GetOut 

func (m *Out) GetOut() int64

func (*Out) ProtoMessage 

func (*Out) ProtoMessage()

func (*Out) Reset 

func (m *Out) Reset()

func (*Out) String 

func (m *Out) String() string

func (*Out) XXX_DiscardUnknown 

func (m *Out) XXX_DiscardUnknown()

func (*Out) XXX_Marshal 

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

func (*Out) XXX_Merge 

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

func (*Out) XXX_Size 

func (m *Out) XXX_Size() int

func (*Out) XXX_Unmarshal 

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