v1

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
  • func (*TopicEventRequest) Descriptor() ([]byte, []int)
  • func (x *TopicEventRequest) GetData() *structpb.Value
  • func (x *TopicEventRequest) GetDataBase64() string
  • func (x *TopicEventRequest) GetDatacontenttype() string
  • func (x *TopicEventRequest) GetId() string
  • func (x *TopicEventRequest) GetPubsubname() string
  • func (x *TopicEventRequest) GetSource() string
  • func (x *TopicEventRequest) GetSpecversion() string
  • func (x *TopicEventRequest) GetSubject() string
  • func (x *TopicEventRequest) GetTopic() string
  • func (x *TopicEventRequest) GetType() string
  • func (*TopicEventRequest) ProtoMessage()
  • func (x *TopicEventRequest) ProtoReflect() protoreflect.Message
  • func (x *TopicEventRequest) Reset()
  • func (x *TopicEventRequest) String() string
• type TopicEventResponse
  • func (*TopicEventResponse) Descriptor() ([]byte, []int)
  • func (x *TopicEventResponse) GetStatus() string
  • func (*TopicEventResponse) ProtoMessage()
  • func (x *TopicEventResponse) ProtoReflect() protoreflect.Message
  • func (x *TopicEventResponse) Reset()
  • func (x *TopicEventResponse) String() string
• 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

Variables

var File_api_topic_topic_proto protoreflect.FileDescriptor

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

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

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.