1# package integration 2 3`import "storj.io/drpc/internal/integration"` 4 5Package integration holds integration tests for drpc. 6 7## Usage 8 9#### func DRPCRegisterService 10 11```go 12func DRPCRegisterService(mux drpc.Mux, impl DRPCServiceServer) error 13``` 14 15#### type DRPCServiceClient 16 17```go 18type DRPCServiceClient interface { 19 DRPCConn() drpc.Conn 20 21 Method1(ctx context.Context, in *In) (*Out, error) 22 Method2(ctx context.Context) (DRPCService_Method2Client, error) 23 Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error) 24 Method4(ctx context.Context) (DRPCService_Method4Client, error) 25} 26``` 27 28 29#### func NewDRPCServiceClient 30 31```go 32func NewDRPCServiceClient(cc drpc.Conn) DRPCServiceClient 33``` 34 35#### type DRPCServiceDescription 36 37```go 38type DRPCServiceDescription struct{} 39``` 40 41 42#### func (DRPCServiceDescription) Method 43 44```go 45func (DRPCServiceDescription) Method(n int) (string, drpc.Receiver, interface{}, bool) 46``` 47 48#### func (DRPCServiceDescription) NumMethods 49 50```go 51func (DRPCServiceDescription) NumMethods() int 52``` 53 54#### type DRPCServiceServer 55 56```go 57type DRPCServiceServer interface { 58 Method1(context.Context, *In) (*Out, error) 59 Method2(DRPCService_Method2Stream) error 60 Method3(*In, DRPCService_Method3Stream) error 61 Method4(DRPCService_Method4Stream) error 62} 63``` 64 65 66#### type DRPCServiceUnimplementedServer 67 68```go 69type DRPCServiceUnimplementedServer struct{} 70``` 71 72 73#### func (*DRPCServiceUnimplementedServer) Method1 74 75```go 76func (s *DRPCServiceUnimplementedServer) Method1(context.Context, *In) (*Out, error) 77``` 78 79#### func (*DRPCServiceUnimplementedServer) Method2 80 81```go 82func (s *DRPCServiceUnimplementedServer) Method2(DRPCService_Method2Stream) error 83``` 84 85#### func (*DRPCServiceUnimplementedServer) Method3 86 87```go 88func (s *DRPCServiceUnimplementedServer) Method3(*In, DRPCService_Method3Stream) error 89``` 90 91#### func (*DRPCServiceUnimplementedServer) Method4 92 93```go 94func (s *DRPCServiceUnimplementedServer) Method4(DRPCService_Method4Stream) error 95``` 96 97#### type DRPCService_Method1Stream 98 99```go 100type DRPCService_Method1Stream interface { 101 drpc.Stream 102 SendAndClose(*Out) error 103} 104``` 105 106 107#### type DRPCService_Method2Client 108 109```go 110type DRPCService_Method2Client interface { 111 drpc.Stream 112 Send(*In) error 113 CloseAndRecv() (*Out, error) 114} 115``` 116 117 118#### type DRPCService_Method2Stream 119 120```go 121type DRPCService_Method2Stream interface { 122 drpc.Stream 123 SendAndClose(*Out) error 124 Recv() (*In, error) 125} 126``` 127 128 129#### type DRPCService_Method3Client 130 131```go 132type DRPCService_Method3Client interface { 133 drpc.Stream 134 Recv() (*Out, error) 135} 136``` 137 138 139#### type DRPCService_Method3Stream 140 141```go 142type DRPCService_Method3Stream interface { 143 drpc.Stream 144 Send(*Out) error 145} 146``` 147 148 149#### type DRPCService_Method4Client 150 151```go 152type DRPCService_Method4Client interface { 153 drpc.Stream 154 Send(*In) error 155 Recv() (*Out, error) 156} 157``` 158 159 160#### type DRPCService_Method4Stream 161 162```go 163type DRPCService_Method4Stream interface { 164 drpc.Stream 165 Send(*Out) error 166 Recv() (*In, error) 167} 168``` 169 170 171#### type In 172 173```go 174type In struct { 175 In int64 `protobuf:"varint,1,opt,name=in,proto3" json:"in,omitempty"` 176 XXX_NoUnkeyedLiteral struct{} `json:"-"` 177 XXX_unrecognized []byte `json:"-"` 178 XXX_sizecache int32 `json:"-"` 179} 180``` 181 182 183#### func (*In) Descriptor 184 185```go 186func (*In) Descriptor() ([]byte, []int) 187``` 188 189#### func (*In) GetIn 190 191```go 192func (m *In) GetIn() int64 193``` 194 195#### func (*In) ProtoMessage 196 197```go 198func (*In) ProtoMessage() 199``` 200 201#### func (*In) Reset 202 203```go 204func (m *In) Reset() 205``` 206 207#### func (*In) String 208 209```go 210func (m *In) String() string 211``` 212 213#### func (*In) XXX_DiscardUnknown 214 215```go 216func (m *In) XXX_DiscardUnknown() 217``` 218 219#### func (*In) XXX_Marshal 220 221```go 222func (m *In) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) 223``` 224 225#### func (*In) XXX_Merge 226 227```go 228func (m *In) XXX_Merge(src proto.Message) 229``` 230 231#### func (*In) XXX_Size 232 233```go 234func (m *In) XXX_Size() int 235``` 236 237#### func (*In) XXX_Unmarshal 238 239```go 240func (m *In) XXX_Unmarshal(b []byte) error 241``` 242 243#### type Out 244 245```go 246type Out struct { 247 Out int64 `protobuf:"varint,1,opt,name=out,proto3" json:"out,omitempty"` 248 XXX_NoUnkeyedLiteral struct{} `json:"-"` 249 XXX_unrecognized []byte `json:"-"` 250 XXX_sizecache int32 `json:"-"` 251} 252``` 253 254 255#### func (*Out) Descriptor 256 257```go 258func (*Out) Descriptor() ([]byte, []int) 259``` 260 261#### func (*Out) GetOut 262 263```go 264func (m *Out) GetOut() int64 265``` 266 267#### func (*Out) ProtoMessage 268 269```go 270func (*Out) ProtoMessage() 271``` 272 273#### func (*Out) Reset 274 275```go 276func (m *Out) Reset() 277``` 278 279#### func (*Out) String 280 281```go 282func (m *Out) String() string 283``` 284 285#### func (*Out) XXX_DiscardUnknown 286 287```go 288func (m *Out) XXX_DiscardUnknown() 289``` 290 291#### func (*Out) XXX_Marshal 292 293```go 294func (m *Out) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) 295``` 296 297#### func (*Out) XXX_Merge 298 299```go 300func (m *Out) XXX_Merge(src proto.Message) 301``` 302 303#### func (*Out) XXX_Size 304 305```go 306func (m *Out) XXX_Size() int 307``` 308 309#### func (*Out) XXX_Unmarshal 310 311```go 312func (m *Out) XXX_Unmarshal(b []byte) error 313``` 314