multiple

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_multiple1_proto protoreflect.FileDescriptor
View Source
var File_multiple2_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Msg1

type Msg1 struct {
	// contains filtered or unexported fields
}

func (*Msg1) Descriptor deprecated

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

Deprecated: Use Msg1.ProtoReflect.Descriptor instead.

func (*Msg1) ProtoMessage

func (*Msg1) ProtoMessage()

func (*Msg1) ProtoReflect

func (x *Msg1) ProtoReflect() protoreflect.Message

func (*Msg1) Reset

func (x *Msg1) Reset()

func (*Msg1) String

func (x *Msg1) String() string

type Msg2

type Msg2 struct {
	// contains filtered or unexported fields
}

func (*Msg2) Descriptor deprecated

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

Deprecated: Use Msg2.ProtoReflect.Descriptor instead.

func (*Msg2) ProtoMessage

func (*Msg2) ProtoMessage()

func (*Msg2) ProtoReflect

func (x *Msg2) ProtoReflect() protoreflect.Message

func (*Msg2) Reset

func (x *Msg2) Reset()

func (*Msg2) String

func (x *Msg2) String() string

type Svc1Client

type Svc1Client interface {
	Send(context.Context, *Msg1, ...psrpc.RequestOpt) (*Msg1, error)
}

func NewSvc1Client

func NewSvc1Client(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOpt) (Svc1Client, error)

NewSvc1Client creates a psrpc client that implements the Svc1Client interface.

type Svc1Server

type Svc1Server interface {
}

func NewSvc1Server

func NewSvc1Server(serverID string, svc Svc1ServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOpt) (Svc1Server, error)

NewSvc1Server builds a RPCServer that can be used to handle requests that are routed to the right method in the provided svc implementation.

type Svc1ServerImpl

type Svc1ServerImpl interface {
	Send(context.Context, *Msg1) (*Msg1, error)
}

type Svc2Client

type Svc2Client interface {
	Send(context.Context, *Msg2, ...psrpc.RequestOpt) (*Msg2, error)

	SamePackageProtoImport(context.Context, *Msg1, ...psrpc.RequestOpt) (*Msg1, error)
}

func NewSvc2Client

func NewSvc2Client(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOpt) (Svc2Client, error)

NewSvc2Client creates a psrpc client that implements the Svc2Client interface.

type Svc2Server

type Svc2Server interface {
}

func NewSvc2Server

func NewSvc2Server(serverID string, svc Svc2ServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOpt) (Svc2Server, error)

NewSvc2Server builds a RPCServer that can be used to handle requests that are routed to the right method in the provided svc implementation.

type Svc2ServerImpl

type Svc2ServerImpl interface {
	Send(context.Context, *Msg2) (*Msg2, error)

	SamePackageProtoImport(context.Context, *Msg1) (*Msg1, error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL