example

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GreetingToAll_NRServiceName = "natsrpc.example.GreetingToAll"
)
View Source 
const (
	Greeting_NRServiceName = "natsrpc.example.Greeting"
)

Variables

View Source 
var GreetingToAll_NRServiceDesc = natsrpc.ServiceDesc{
	ServiceName: GreetingToAll_NRServiceName,
	Methods: []natsrpc.MethodDesc{
		{
			MethodName:  "HelloToAll",
			Handler:     _GreetingToAll_HelloToAll_NRHandler,
			RequestType: reflect.TypeOf(HelloRequest{}),
			IsPublish:   true,
		},
	},
	Metadata: "example.proto",
}
View Source 
var Greeting_NRServiceDesc = natsrpc.ServiceDesc{
	ServiceName: Greeting_NRServiceName,
	Methods: []natsrpc.MethodDesc{
		{
			MethodName:  "Hello",
			Handler:     _Greeting_Hello_NRHandler,
			RequestType: reflect.TypeOf(HelloRequest{}),
			IsPublish:   false,
		},
	},
	Metadata: "example.proto",
}

Functions

func IfNotNilPanic added in v0.6.0 

func IfNotNilPanic(err error)

func RegisterGreetingNRServer added in v0.7.0 

func RegisterGreetingNRServer(register natsrpc.ServiceRegistrar, s GreetingNRServer, opts ...natsrpc.ServiceOption) (natsrpc.ServiceInterface, error)

func RegisterGreetingToAllNRServer added in v0.7.0 

func RegisterGreetingToAllNRServer(register natsrpc.ServiceRegistrar, s GreetingToAllNRServer, opts ...natsrpc.ServiceOption) (natsrpc.ServiceInterface, error)

Types

type Empty added in v0.6.0 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor added in v0.6.0 

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

func (*Empty) ProtoMessage added in v0.6.0 

func (*Empty) ProtoMessage()

func (*Empty) Reset added in v0.6.0 

func (m *Empty) Reset()

func (*Empty) String added in v0.6.0 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown added in v0.7.0 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal added in v0.7.0 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge added in v0.7.0 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size added in v0.7.0 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal added in v0.7.0 

func (m *Empty) XXX_Unmarshal(b []byte) error

type GreetingNRClient added in v0.7.0 

type GreetingNRClient interface {
	Hello(ctx context.Context, req *HelloRequest, opt ...natsrpc.CallOption) (*HelloReply, error)
}

func NewGreetingNRClient added in v0.7.0 

func NewGreetingNRClient(c natsrpc.ClientInterface) GreetingNRClient

NewGreetingNRClient

type GreetingNRServer added in v0.7.0 

type GreetingNRServer interface {
	Hello(ctx context.Context, req *HelloRequest) (*HelloReply, error)
}

type GreetingToAllNRClient added in v0.7.0 

type GreetingToAllNRClient interface {
	HelloToAll(notify *HelloRequest, opt ...natsrpc.CallOption) error
}

func NewGreetingToAllNRClient added in v0.7.0 

func NewGreetingToAllNRClient(c natsrpc.ClientInterface) GreetingToAllNRClient

NewGreetingToAllNRClient

type GreetingToAllNRServer added in v0.7.0 

type GreetingToAllNRServer interface {
	HelloToAll(ctx context.Context, req *HelloRequest) (*Empty, error)
}

type HelloReply added in v0.6.0 

type HelloReply struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HelloReply) Descriptor added in v0.6.0 

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

func (*HelloReply) GetMessage added in v0.6.0 

func (m *HelloReply) GetMessage() string

func (*HelloReply) ProtoMessage added in v0.6.0 

func (*HelloReply) ProtoMessage()

func (*HelloReply) Reset added in v0.6.0 

func (m *HelloReply) Reset()

func (*HelloReply) String added in v0.6.0 

func (m *HelloReply) String() string

func (*HelloReply) XXX_DiscardUnknown added in v0.7.0 

func (m *HelloReply) XXX_DiscardUnknown()

func (*HelloReply) XXX_Marshal added in v0.7.0 

func (m *HelloReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HelloReply) XXX_Merge added in v0.7.0 

func (m *HelloReply) XXX_Merge(src proto.Message)

func (*HelloReply) XXX_Size added in v0.7.0 

func (m *HelloReply) XXX_Size() int

func (*HelloReply) XXX_Unmarshal added in v0.7.0 

func (m *HelloReply) XXX_Unmarshal(b []byte) error

type HelloRequest added in v0.6.0 

type HelloRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HelloRequest) Descriptor added in v0.6.0 

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

func (*HelloRequest) GetName added in v0.6.0 

func (m *HelloRequest) GetName() string

func (*HelloRequest) ProtoMessage added in v0.6.0 

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset added in v0.6.0 

func (m *HelloRequest) Reset()

func (*HelloRequest) String added in v0.6.0 

func (m *HelloRequest) String() string

func (*HelloRequest) XXX_DiscardUnknown added in v0.7.0 

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal added in v0.7.0 

func (m *HelloRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HelloRequest) XXX_Merge added in v0.7.0 

func (m *HelloRequest) XXX_Merge(src proto.Message)

func (*HelloRequest) XXX_Size added in v0.7.0 

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal added in v0.7.0 

func (m *HelloRequest) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis
tool
publish_bench
request_bench

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.