integration

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

README

package integration

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

Package integration holds integration tests for drpc.

Usage

func DRPCRegisterService
func DRPCRegisterService(srv drpc.Server, impl DRPCServiceServer)
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

Documentation

Overview

Package integration holds integration tests for drpc.

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.