Documentation ¶
Index ¶
- Variables
- func RegisterLinkCommandServiceServer(s grpc.ServiceRegistrar, srv LinkCommandServiceServer)
- func RegisterLinkQueryServiceServer(s grpc.ServiceRegistrar, srv LinkQueryServiceServer)
- type AddRequest
- type AddResponse
- type DeleteRequest
- type GetRequest
- type GetResponse
- type Link
- type LinkCommandServiceClient
- type LinkCommandServiceServer
- type LinkQueryServiceClient
- type LinkQueryServiceServer
- type ListRequest
- type ListResponse
- type UnimplementedLinkCommandServiceServer
- func (UnimplementedLinkCommandServiceServer) Add(context.Context, *AddRequest) (*AddResponse, error)
- func (UnimplementedLinkCommandServiceServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
- func (UnimplementedLinkCommandServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
- type UnimplementedLinkQueryServiceServer
- type UnsafeLinkCommandServiceServer
- type UnsafeLinkQueryServiceServer
- type UpdateRequest
- type UpdateResponse
Constants ¶
This section is empty.
Variables ¶
var File_infrastructure_rpc_cqrs_link_v1_link_command_proto protoreflect.FileDescriptor
var File_infrastructure_rpc_cqrs_link_v1_link_query_proto protoreflect.FileDescriptor
var LinkCommandService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "infrastructure.rpc.cqrs.link.v1.LinkCommandService", HandlerType: (*LinkCommandServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Add", Handler: _LinkCommandService_Add_Handler, }, { MethodName: "Update", Handler: _LinkCommandService_Update_Handler, }, { MethodName: "Delete", Handler: _LinkCommandService_Delete_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "infrastructure/rpc/cqrs/link/v1/link_command.proto", }
LinkCommandService_ServiceDesc is the grpc.ServiceDesc for LinkCommandService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var LinkQueryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "infrastructure.rpc.cqrs.link.v1.LinkQueryService", HandlerType: (*LinkQueryServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _LinkQueryService_Get_Handler, }, { MethodName: "List", Handler: _LinkQueryService_List_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "infrastructure/rpc/cqrs/link/v1/link_query.proto", }
LinkQueryService_ServiceDesc is the grpc.ServiceDesc for LinkQueryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLinkCommandServiceServer ¶
func RegisterLinkCommandServiceServer(s grpc.ServiceRegistrar, srv LinkCommandServiceServer)
func RegisterLinkQueryServiceServer ¶
func RegisterLinkQueryServiceServer(s grpc.ServiceRegistrar, srv LinkQueryServiceServer)
Types ¶
type AddRequest ¶
type AddRequest struct { Link *v1.Link `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
func (*AddRequest) Descriptor
deprecated
func (*AddRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.
func (*AddRequest) GetLink ¶
func (x *AddRequest) GetLink() *v1.Link
func (*AddRequest) ProtoMessage ¶
func (*AddRequest) ProtoMessage()
func (*AddRequest) ProtoReflect ¶
func (x *AddRequest) ProtoReflect() protoreflect.Message
func (*AddRequest) Reset ¶
func (x *AddRequest) Reset()
func (*AddRequest) String ¶
func (x *AddRequest) String() string
type AddResponse ¶
type AddResponse struct { Link *v1.Link `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
func (*AddResponse) Descriptor
deprecated
func (*AddResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddResponse.ProtoReflect.Descriptor instead.
func (*AddResponse) GetLink ¶
func (x *AddResponse) GetLink() *v1.Link
func (*AddResponse) ProtoMessage ¶
func (*AddResponse) ProtoMessage()
func (*AddResponse) ProtoReflect ¶
func (x *AddResponse) ProtoReflect() protoreflect.Message
func (*AddResponse) Reset ¶
func (x *AddResponse) Reset()
func (*AddResponse) String ¶
func (x *AddResponse) String() string
type DeleteRequest ¶
type DeleteRequest struct { Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetHash ¶
func (x *DeleteRequest) GetHash() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type GetRequest ¶
type GetRequest struct { Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetHash ¶
func (x *GetRequest) GetHash() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetResponse ¶
type GetResponse struct { Link *v1.LinkView `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetLink ¶
func (x *GetResponse) GetLink() *v1.LinkView
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type Link ¶
type Link struct { LinkCommandServiceServer LinkQueryServiceServer // contains filtered or unexported fields }
func (*Link) Get ¶
func (l *Link) Get(ctx context.Context, in *GetRequest) (*GetResponse, error)
func (*Link) List ¶
func (l *Link) List(ctx context.Context, in *ListRequest) (*ListResponse, error)
type LinkCommandServiceClient ¶
type LinkCommandServiceClient interface { Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
LinkCommandServiceClient is the client API for LinkCommandService 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 NewLinkCommandServiceClient ¶
func NewLinkCommandServiceClient(cc grpc.ClientConnInterface) LinkCommandServiceClient
type LinkCommandServiceServer ¶
type LinkCommandServiceServer interface { Add(context.Context, *AddRequest) (*AddResponse, error) Update(context.Context, *UpdateRequest) (*UpdateResponse, error) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
LinkCommandServiceServer is the server API for LinkCommandService service. All implementations must embed UnimplementedLinkCommandServiceServer for forward compatibility
type LinkQueryServiceClient ¶
type LinkQueryServiceClient interface { Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) }
LinkQueryServiceClient is the client API for LinkQueryService 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 NewLinkQueryServiceClient ¶
func NewLinkQueryServiceClient(cc grpc.ClientConnInterface) LinkQueryServiceClient
type LinkQueryServiceServer ¶
type LinkQueryServiceServer interface { Get(context.Context, *GetRequest) (*GetResponse, error) List(context.Context, *ListRequest) (*ListResponse, error) // contains filtered or unexported methods }
LinkQueryServiceServer is the server API for LinkQueryService service. All implementations must embed UnimplementedLinkQueryServiceServer for forward compatibility
type ListRequest ¶
type ListRequest struct { Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetFilter ¶
func (x *ListRequest) GetFilter() string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Links *v1.LinksView `protobuf:"bytes,1,opt,name=links,proto3" json:"links,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetLinks ¶
func (x *ListResponse) GetLinks() *v1.LinksView
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type UnimplementedLinkCommandServiceServer ¶
type UnimplementedLinkCommandServiceServer struct { }
UnimplementedLinkCommandServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedLinkCommandServiceServer) Add ¶
func (UnimplementedLinkCommandServiceServer) Add(context.Context, *AddRequest) (*AddResponse, error)
func (UnimplementedLinkCommandServiceServer) Delete ¶
func (UnimplementedLinkCommandServiceServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)
func (UnimplementedLinkCommandServiceServer) Update ¶
func (UnimplementedLinkCommandServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
type UnimplementedLinkQueryServiceServer ¶
type UnimplementedLinkQueryServiceServer struct { }
UnimplementedLinkQueryServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedLinkQueryServiceServer) Get ¶
func (UnimplementedLinkQueryServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedLinkQueryServiceServer) List ¶
func (UnimplementedLinkQueryServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)
type UnsafeLinkCommandServiceServer ¶
type UnsafeLinkCommandServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLinkCommandServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LinkCommandServiceServer will result in compilation errors.
type UnsafeLinkQueryServiceServer ¶
type UnsafeLinkQueryServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLinkQueryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LinkQueryServiceServer will result in compilation errors.
type UpdateRequest ¶
type UpdateRequest struct { Link *v1.Link `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
func (*UpdateRequest) Descriptor
deprecated
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetLink ¶
func (x *UpdateRequest) GetLink() *v1.Link
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateResponse ¶
type UpdateResponse struct { Link *v1.Link `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"` // contains filtered or unexported fields }
func (*UpdateResponse) Descriptor
deprecated
func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) GetLink ¶
func (x *UpdateResponse) GetLink() *v1.Link
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (x *UpdateResponse) String() string