v1

package

v0.4.6 Latest Latest Go to latest Published: Mar 31, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tkeel-io/core-broker

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterTopicHTTPServer(container *go_restful.Container, srv TopicHTTPServer)
func RegisterTopicServer(s grpc.ServiceRegistrar, srv TopicServer)
type TopicClient
- func NewTopicClient(cc grpc.ClientConnInterface) TopicClient
type TopicEventRequest
type TopicEventResponse
type TopicHTTPHandler
- func (h *TopicHTTPHandler) TopicEventHandler(req *go_restful.Request, resp *go_restful.Response)
type TopicHTTPServer
type TopicServer
type UnimplementedTopicServer
- func (UnimplementedTopicServer) TopicEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
type UnsafeTopicServer

Constants ¶

This section is empty.

Variables ¶

View Source

var File_api_topic_topic_proto protoreflect.FileDescriptor

View Source

var Topic_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.core.v1.Topic",
	HandlerType: (*TopicServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TopicEventHandler",
			Handler:    _Topic_TopicEventHandler_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/topic/topic.proto",
}

Topic_ServiceDesc is the grpc.ServiceDesc for Topic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions ¶

func RegisterTopicHTTPServer ¶

func RegisterTopicHTTPServer(container *go_restful.Container, srv TopicHTTPServer)

func RegisterTopicServer ¶

func RegisterTopicServer(s grpc.ServiceRegistrar, srv TopicServer)

Types ¶

type TopicClient ¶

type TopicClient interface {
	TopicEventHandler(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*TopicEventResponse, error)
}

TopicClient is the client API for Topic 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 NewTopicClient ¶

func NewTopicClient(cc grpc.ClientConnInterface) TopicClient

type TopicEventRequest ¶

type TopicEventRequest struct {
	Id              string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Specversion     string          `protobuf:"bytes,2,opt,name=specversion,proto3" json:"specversion,omitempty"`
	Type            string          `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Source          string          `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Datacontenttype string          `protobuf:"bytes,5,opt,name=datacontenttype,proto3" json:"datacontenttype,omitempty"`
	Data            *structpb.Value `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	DataBase64      string          `protobuf:"bytes,7,opt,name=data_base64,json=dataBase64,proto3" json:"data_base64,omitempty"`
	Subject         string          `protobuf:"bytes,8,opt,name=subject,proto3" json:"subject,omitempty"`
	Topic           string          `protobuf:"bytes,9,opt,name=topic,proto3" json:"topic,omitempty"`
	Pubsubname      string          `protobuf:"bytes,10,opt,name=pubsubname,proto3" json:"pubsubname,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicEventRequest) Descriptor deprecated

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

Deprecated: Use TopicEventRequest.ProtoReflect.Descriptor instead.

func (*TopicEventRequest) GetData ¶

func (x *TopicEventRequest) GetData() *structpb.Value

func (*TopicEventRequest) GetDataBase64 ¶

func (x *TopicEventRequest) GetDataBase64() string

func (*TopicEventRequest) GetDatacontenttype ¶

func (x *TopicEventRequest) GetDatacontenttype() string

func (*TopicEventRequest) GetId ¶

func (x *TopicEventRequest) GetId() string

func (*TopicEventRequest) GetPubsubname ¶

func (x *TopicEventRequest) GetPubsubname() string

func (*TopicEventRequest) GetSource ¶

func (x *TopicEventRequest) GetSource() string

func (*TopicEventRequest) GetSpecversion ¶

func (x *TopicEventRequest) GetSpecversion() string

func (*TopicEventRequest) GetSubject ¶

func (x *TopicEventRequest) GetSubject() string

func (*TopicEventRequest) GetTopic ¶

func (x *TopicEventRequest) GetTopic() string

func (*TopicEventRequest) GetType ¶

func (x *TopicEventRequest) GetType() string

func (*TopicEventRequest) ProtoMessage ¶

func (*TopicEventRequest) ProtoMessage()

func (*TopicEventRequest) ProtoReflect ¶

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

func (*TopicEventRequest) Reset ¶

func (x *TopicEventRequest) Reset()

func (*TopicEventRequest) String ¶

func (x *TopicEventRequest) String() string

type TopicEventResponse ¶

type TopicEventResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicEventResponse) Descriptor deprecated

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

Deprecated: Use TopicEventResponse.ProtoReflect.Descriptor instead.

func (*TopicEventResponse) GetStatus ¶

func (x *TopicEventResponse) GetStatus() string

func (*TopicEventResponse) ProtoMessage ¶

func (*TopicEventResponse) ProtoMessage()

func (*TopicEventResponse) ProtoReflect ¶

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

func (*TopicEventResponse) Reset ¶

func (x *TopicEventResponse) Reset()

func (*TopicEventResponse) String ¶

func (x *TopicEventResponse) String() string

type TopicHTTPHandler ¶

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

func (*TopicHTTPHandler) TopicEventHandler ¶

func (h *TopicHTTPHandler) TopicEventHandler(req *go_restful.Request, resp *go_restful.Response)

type TopicHTTPServer ¶

type TopicHTTPServer interface {
	TopicEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
}

type TopicServer ¶

type TopicServer interface {
	TopicEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
	// contains filtered or unexported methods
}

TopicServer is the server API for Topic service. All implementations must embed UnimplementedTopicServer for forward compatibility

type UnimplementedTopicServer ¶

type UnimplementedTopicServer struct {
}

UnimplementedTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedTopicServer) TopicEventHandler ¶

func (UnimplementedTopicServer) TopicEventHandler(context.Context, *TopicEventRequest) (*TopicEventResponse, error)

type UnsafeTopicServer ¶

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

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

Source Files ¶

View all Source files

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