proto

Documentation

Index

• Variables
• func RegisterCoreServer(s grpc.ServiceRegistrar, srv CoreServer)
• type CoreClient
  • func NewCoreClient(cc grpc.ClientConnInterface) CoreClient
• type CoreServer
• type PublishRequest
  • func (*PublishRequest) Descriptor() ([]byte, []int)
  • func (x *PublishRequest) GetMessage() *anypb.Any
  • func (*PublishRequest) ProtoMessage()
  • func (x *PublishRequest) ProtoReflect() protoreflect.Message
  • func (x *PublishRequest) Reset()
  • func (x *PublishRequest) String() string
• type PublishResponse
  • func (*PublishResponse) Descriptor() ([]byte, []int)
  • func (*PublishResponse) ProtoMessage()
  • func (x *PublishResponse) ProtoReflect() protoreflect.Message
  • func (x *PublishResponse) Reset()
  • func (x *PublishResponse) String() string
• type UnimplementedCoreServer
  • func (UnimplementedCoreServer) Echo(context.Context, *anypb.Any) (*emptypb.Empty, error)
  • func (UnimplementedCoreServer) Publish(context.Context, *anypb.Any) (*emptypb.Empty, error)
• type UnsafeCoreServer
• type Version
  • func (*Version) Descriptor() ([]byte, []int)
  • func (x *Version) GetTopic() string
  • func (x *Version) GetVersion() string
  • func (*Version) ProtoMessage()
  • func (x *Version) ProtoReflect() protoreflect.Message
  • func (x *Version) Reset()
  • func (x *Version) String() string

Variables

var File_cli_proto protoreflect.FileDescriptor

var File_std_proto protoreflect.FileDescriptor

Functions

func RegisterCoreServer

func RegisterCoreServer(s grpc.ServiceRegistrar, srv CoreServer)

Types

type CoreClient

type CoreClient interface {
	Publish(ctx context.Context, in *anypb.Any, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Echo(ctx context.Context, in *anypb.Any, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

CoreClient is the client API for Core service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCoreClient

func NewCoreClient(cc grpc.ClientConnInterface) CoreClient

type CoreServer

type CoreServer interface {
	Publish(context.Context, *anypb.Any) (*emptypb.Empty, error)
	Echo(context.Context, *anypb.Any) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

CoreServer is the server API for Core service. All implementations must embed UnimplementedCoreServer for forward compatibility

type PublishRequest

type PublishRequest struct {
	Message *anypb.Any `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetMessage

func (x *PublishRequest) GetMessage() *anypb.Any

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) String

func (x *PublishRequest) String() string

type PublishResponse

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

func (*PublishResponse) Descriptor

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) ProtoMessage

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect

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

func (*PublishResponse) Reset

func (x *PublishResponse) Reset()

func (*PublishResponse) String

func (x *PublishResponse) String() string

type UnimplementedCoreServer

type UnimplementedCoreServer struct {
}

UnimplementedCoreServer must be embedded to have forward compatible implementations.

func (UnimplementedCoreServer) Echo

func (UnimplementedCoreServer) Echo(context.Context, *anypb.Any) (*emptypb.Empty, error)

func (UnimplementedCoreServer) Publish

func (UnimplementedCoreServer) Publish(context.Context, *anypb.Any) (*emptypb.Empty, error)

type UnsafeCoreServer

type UnsafeCoreServer interface {
	// contains filtered or unexported methods
}

UnsafeCoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CoreServer will result in compilation errors.

type Version

type Version struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Version) Descriptor

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetTopic

func (x *Version) GetTopic() string

func (*Version) GetVersion

func (x *Version) GetVersion() string

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) ProtoReflect

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

func (*Version) Reset

func (x *Version) Reset()

func (*Version) String

func (x *Version) String() string