rpctest

Documentation

Overview

Package rpctest is a generated protocol buffer package.

It is generated from these files:

go.thethings.network/lorawan-stack/v3/pkg/rpctest/rpctest.proto

It has these top-level messages:

Foo
Bar

Index

• Variables
• func RegisterFooBarServer(s *grpc.Server, srv FooBarServer)
• type Bar
  • func NewPopulatedBar(r randyRpctest, easy bool) *Bar
  • func (*Bar) Descriptor() ([]byte, []int)
  • func (this *Bar) Equal(that interface{}) bool
  • func (m *Bar) GetMessage() string
  • func (m *Bar) Marshal() (dAtA []byte, err error)
  • func (m *Bar) MarshalTo(dAtA []byte) (int, error)
  • func (*Bar) ProtoMessage()
  • func (m *Bar) Reset()
  • func (m *Bar) Size() (n int)
  • func (m *Bar) String() string
  • func (m *Bar) Unmarshal(dAtA []byte) error
  • func (this *Bar) VerboseEqual(that interface{}) error
• type Foo
  • func NewPopulatedFoo(r randyRpctest, easy bool) *Foo
  • func (*Foo) Descriptor() ([]byte, []int)
  • func (this *Foo) Equal(that interface{}) bool
  • func (m *Foo) GetMessage() string
  • func (m *Foo) Marshal() (dAtA []byte, err error)
  • func (m *Foo) MarshalTo(dAtA []byte) (int, error)
  • func (*Foo) ProtoMessage()
  • func (m *Foo) Reset()
  • func (m *Foo) Size() (n int)
  • func (m *Foo) String() string
  • func (m *Foo) Unmarshal(dAtA []byte) error
  • func (this *Foo) VerboseEqual(that interface{}) error
• type FooBarClient
  • func NewFooBarClient(cc *grpc.ClientConn) FooBarClient
• type FooBarExampleServer
  • func (s *FooBarExampleServer) BidiStream(stream FooBar_BidiStreamServer) error
  • func (s *FooBarExampleServer) ClientStream(stream FooBar_ClientStreamServer) error
  • func (s *FooBarExampleServer) ServerStream(foo *Foo, stream FooBar_ServerStreamServer) error
  • func (s *FooBarExampleServer) Unary(ctx context.Context, foo *Foo) (*Bar, error)
• type FooBarServer
• type FooBar_BidiStreamClient
• type FooBar_BidiStreamServer
• type FooBar_ClientStreamClient
• type FooBar_ClientStreamServer
• type FooBar_ServerStreamClient
• type FooBar_ServerStreamServer

Variables

var (
	ErrInvalidLengthRpctest = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpctest   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterFooBarServer

func RegisterFooBarServer(s *grpc.Server, srv FooBarServer)

Types

type Bar

type Bar struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func NewPopulatedBar

func NewPopulatedBar(r randyRpctest, easy bool) *Bar

func (*Bar) Descriptor

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

func (*Bar) Equal

func (this *Bar) Equal(that interface{}) bool

func (*Bar) GetMessage

func (m *Bar) GetMessage() string

func (*Bar) Marshal

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

func (*Bar) MarshalTo

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

func (*Bar) ProtoMessage

func (*Bar) ProtoMessage()

func (*Bar) Reset

func (m *Bar) Reset()

func (*Bar) Size

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

func (*Bar) String

func (m *Bar) String() string

func (*Bar) Unmarshal

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

func (*Bar) VerboseEqual

func (this *Bar) VerboseEqual(that interface{}) error

type Foo

type Foo struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func NewPopulatedFoo

func NewPopulatedFoo(r randyRpctest, easy bool) *Foo

func (*Foo) Descriptor

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

func (*Foo) Equal

func (this *Foo) Equal(that interface{}) bool

func (*Foo) GetMessage

func (m *Foo) GetMessage() string

func (*Foo) Marshal

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

func (*Foo) MarshalTo

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

func (*Foo) ProtoMessage

func (*Foo) ProtoMessage()

func (*Foo) Reset

func (m *Foo) Reset()

func (*Foo) Size

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

func (*Foo) String

func (m *Foo) String() string

func (*Foo) Unmarshal

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

func (*Foo) VerboseEqual

func (this *Foo) VerboseEqual(that interface{}) error

type FooBarClient

type FooBarClient interface {
	Unary(ctx context.Context, in *Foo, opts ...grpc.CallOption) (*Bar, error)
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (FooBar_ClientStreamClient, error)
	ServerStream(ctx context.Context, in *Foo, opts ...grpc.CallOption) (FooBar_ServerStreamClient, error)
	BidiStream(ctx context.Context, opts ...grpc.CallOption) (FooBar_BidiStreamClient, error)
}

func NewFooBarClient

func NewFooBarClient(cc *grpc.ClientConn) FooBarClient

type FooBarExampleServer

type FooBarExampleServer struct{}

The FooBarExampleServer is an example/test server

func (*FooBarExampleServer) BidiStream

func (s *FooBarExampleServer) BidiStream(stream FooBar_BidiStreamServer) error

BidiStream RPC example

func (*FooBarExampleServer) ClientStream

func (s *FooBarExampleServer) ClientStream(stream FooBar_ClientStreamServer) error

ClientStream RPC example

func (*FooBarExampleServer) ServerStream

func (s *FooBarExampleServer) ServerStream(foo *Foo, stream FooBar_ServerStreamServer) error

ServerStream RPC example

func (*FooBarExampleServer) Unary

func (s *FooBarExampleServer) Unary(ctx context.Context, foo *Foo) (*Bar, error)

Unary RPC example

type FooBarServer

type FooBarServer interface {
	Unary(context.Context, *Foo) (*Bar, error)
	ClientStream(FooBar_ClientStreamServer) error
	ServerStream(*Foo, FooBar_ServerStreamServer) error
	BidiStream(FooBar_BidiStreamServer) error
}

type FooBar_BidiStreamClient

type FooBar_BidiStreamClient interface {
	Send(*Foo) error
	Recv() (*Bar, error)
	grpc.ClientStream
}

type FooBar_BidiStreamServer

type FooBar_BidiStreamServer interface {
	Send(*Bar) error
	Recv() (*Foo, error)
	grpc.ServerStream
}

type FooBar_ClientStreamClient

type FooBar_ClientStreamClient interface {
	Send(*Foo) error
	CloseAndRecv() (*Bar, error)
	grpc.ClientStream
}

type FooBar_ClientStreamServer

type FooBar_ClientStreamServer interface {
	SendAndClose(*Bar) error
	Recv() (*Foo, error)
	grpc.ServerStream
}

type FooBar_ServerStreamClient

type FooBar_ServerStreamClient interface {
	Recv() (*Bar, error)
	grpc.ClientStream
}

type FooBar_ServerStreamServer

type FooBar_ServerStreamServer interface {
	Send(*Bar) error
	grpc.ServerStream
}