Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.
Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterSourceServiceServer(s grpc.ServiceRegistrar, srv SourceServiceServer)
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishRequest) GetAfter() []byte
- func (x *PublishRequest) GetBefore() []byte
- func (x *PublishRequest) GetId() string
- func (x *PublishRequest) GetMetadata() map[string]string
- func (x *PublishRequest) GetOperation() string
- func (x *PublishRequest) GetPath() string
- func (x *PublishRequest) GetPayload() []byte
- func (x *PublishRequest) GetSchema() string
- func (x *PublishRequest) GetTable() string
- 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)deprecated
- func (x *PublishResponse) GetId() string
- func (x *PublishResponse) GetStatus() string
- func (*PublishResponse) ProtoMessage()
- func (x *PublishResponse) ProtoReflect() protoreflect.Message
- func (x *PublishResponse) Reset()
- func (x *PublishResponse) String() string
- type SourceServiceClient
- type SourceServiceServer
- type UnimplementedSourceServiceServer
- type UnsafeSourceServiceServer
Constants ¶
View Source
const (
SourceService_Publish_FullMethodName = "/hermod.source.grpc.v1.SourceService/Publish"
)
Variables ¶
View Source
var File_pkg_source_grpc_proto_source_proto protoreflect.FileDescriptor
View Source
var SourceService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "hermod.source.grpc.v1.SourceService", HandlerType: (*SourceServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Publish", Handler: _SourceService_Publish_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/source/grpc/proto/source.proto", }
SourceService_ServiceDesc is the grpc.ServiceDesc for SourceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSourceServiceServer ¶
func RegisterSourceServiceServer(s grpc.ServiceRegistrar, srv SourceServiceServer)
Types ¶
type PublishRequest ¶
type PublishRequest struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
Operation string `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
Table string `protobuf:"bytes,4,opt,name=table,proto3" json:"table,omitempty"`
Schema string `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
Before []byte `protobuf:"bytes,6,opt,name=before,proto3" json:"before,omitempty"`
After []byte `protobuf:"bytes,7,opt,name=after,proto3" json:"after,omitempty"`
Payload []byte `protobuf:"bytes,8,opt,name=payload,proto3" json:"payload,omitempty"`
Metadata map[string]string `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*PublishRequest) Descriptor
deprecated
func (*PublishRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.
func (*PublishRequest) GetAfter ¶
func (x *PublishRequest) GetAfter() []byte
func (*PublishRequest) GetBefore ¶
func (x *PublishRequest) GetBefore() []byte
func (*PublishRequest) GetId ¶
func (x *PublishRequest) GetId() string
func (*PublishRequest) GetMetadata ¶
func (x *PublishRequest) GetMetadata() map[string]string
func (*PublishRequest) GetOperation ¶
func (x *PublishRequest) GetOperation() string
func (*PublishRequest) GetPath ¶
func (x *PublishRequest) GetPath() string
func (*PublishRequest) GetPayload ¶
func (x *PublishRequest) GetPayload() []byte
func (*PublishRequest) GetSchema ¶
func (x *PublishRequest) GetSchema() string
func (*PublishRequest) GetTable ¶
func (x *PublishRequest) GetTable() string
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 {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*PublishResponse) Descriptor
deprecated
func (*PublishResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.
func (*PublishResponse) GetId ¶
func (x *PublishResponse) GetId() string
func (*PublishResponse) GetStatus ¶
func (x *PublishResponse) GetStatus() string
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 SourceServiceClient ¶
type SourceServiceClient interface {
Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
}
SourceServiceClient is the client API for SourceService 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 NewSourceServiceClient ¶
func NewSourceServiceClient(cc grpc.ClientConnInterface) SourceServiceClient
type SourceServiceServer ¶
type SourceServiceServer interface {
Publish(context.Context, *PublishRequest) (*PublishResponse, error)
// contains filtered or unexported methods
}
SourceServiceServer is the server API for SourceService service. All implementations must embed UnimplementedSourceServiceServer for forward compatibility
type UnimplementedSourceServiceServer ¶
type UnimplementedSourceServiceServer struct {
}
UnimplementedSourceServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSourceServiceServer) Publish ¶
func (UnimplementedSourceServiceServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)
type UnsafeSourceServiceServer ¶
type UnsafeSourceServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSourceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SourceServiceServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.