Movatterモバイル変換


[0]ホーム

URL:


integration

packagemodule
v0.0.0-...-1f5426fLatest Latest
Warning

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

Go to latest
Published: Jul 14, 2025 License:MITImports:1Imported by:0

Details

Repository

github.com/storj/drpc

Links

README

package integration

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

Package integration holds integration tests for drpc.

Usage

func DRPCRegisterService
func DRPCRegisterService(mux drpc.Mux, impl DRPCServiceServer) error
type DRPCServiceClient
type DRPCServiceClient interface {DRPCConn() drpc.ConnMethod1(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.Receiver, interface{}, bool)
func (DRPCServiceDescription) NumMethods
func (DRPCServiceDescription) NumMethods() int
type DRPCServiceServer
type DRPCServiceServer interface {Method1(context.Context, *In) (*Out, error)Method2(DRPCService_Method2Stream) errorMethod3(*In, DRPCService_Method3Stream) errorMethod4(DRPCService_Method4Stream) error}
type DRPCServiceUnimplementedServer
type DRPCServiceUnimplementedServer struct{}
func (*DRPCServiceUnimplementedServer) Method1
func (s *DRPCServiceUnimplementedServer) Method1(context.Context, *In) (*Out, error)
func (*DRPCServiceUnimplementedServer) Method2
func (s *DRPCServiceUnimplementedServer) Method2(DRPCService_Method2Stream) error
func (*DRPCServiceUnimplementedServer) Method3
func (s *DRPCServiceUnimplementedServer) Method3(*In, DRPCService_Method3Stream) error
func (*DRPCServiceUnimplementedServer) Method4
func (s *DRPCServiceUnimplementedServer) Method4(DRPCService_Method4Stream) error
type DRPCService_Method1Stream
type DRPCService_Method1Stream interface {drpc.StreamSendAndClose(*Out) error}
type DRPCService_Method2Client
type DRPCService_Method2Client interface {drpc.StreamSend(*In) errorCloseAndRecv() (*Out, error)}
type DRPCService_Method2Stream
type DRPCService_Method2Stream interface {drpc.StreamSendAndClose(*Out) errorRecv() (*In, error)}
type DRPCService_Method3Client
type DRPCService_Method3Client interface {drpc.StreamRecv() (*Out, error)}
type DRPCService_Method3Stream
type DRPCService_Method3Stream interface {drpc.StreamSend(*Out) error}
type DRPCService_Method4Client
type DRPCService_Method4Client interface {drpc.StreamSend(*In) errorRecv() (*Out, error)}
type DRPCService_Method4Stream
type DRPCService_Method4Stream interface {drpc.StreamSend(*Out) errorRecv() (*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

View Source
var (NewDRPCServiceClient =service.NewDRPCServiceClientDRPCRegisterService  =service.DRPCRegisterServiceEqual                =service.EqualEncoding             =service.Encoding)

Functions

This section is empty.

Types

typeDRPCServiceClient

type DRPCServiceClient =service.DRPCServiceClient

typeDRPCServiceServer

type DRPCServiceServer =service.DRPCServiceServer

typeIn

type In =service.In

typeOut

type Out =service.Out

Source Files

View all Source files

Directories

PathSynopsis
Package customencoding is a testing custom encoding for the integration tests.
Package customencoding is a testing custom encoding for the integration tests.
Package service is a testing service for the integration tests.
Package service is a testing service for the integration tests.
Package service is a testing service for the integration tests.
Package service is a testing service for the integration tests.
Package service is a testing service for the integration tests.
Package service is a testing service for the integration tests.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f orF : Jump to
y orY : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic.Learn more.

[8]ページ先頭

©2009-2025 Movatter.jp