pb

package
v0.0.0-...-97b9ebb Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 25, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_manager_proto protoreflect.FileDescriptor
View Source 
var File_resource_proto protoreflect.FileDescriptor
View Source 
var File_tcommit_proto protoreflect.FileDescriptor
View Source 
var ManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "degitx.tcommit.ManagerService",
	HandlerType: (*ManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Begin",
			Handler:    _ManagerService_Begin_Handler,
		},
		{
			MethodName: "Finish",
			Handler:    _ManagerService_Finish_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manager.proto",
}

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

View Source 
var ResourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "degitx.tcommit.ResourceService",
	HandlerType: (*ResourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Commit",
			Handler:    _ResourceService_Commit_Handler,
		},
		{
			MethodName: "Abort",
			Handler:    _ResourceService_Abort_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "resource.proto",
}

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

Functions

func RegisterManagerServiceServer 

func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)

func RegisterResourceServiceServer 

func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

Types

type AbortRequest 

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

AbortRequest command to resource manager

func (*AbortRequest) Descriptor deprecated 

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

Deprecated: Use AbortRequest.ProtoReflect.Descriptor instead.

func (*AbortRequest) ProtoMessage 

func (*AbortRequest) ProtoMessage()

func (*AbortRequest) ProtoReflect 

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

func (*AbortRequest) Reset 

func (x *AbortRequest) Reset()

func (*AbortRequest) String 

func (x *AbortRequest) String() string

type AbortResponse 

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

AbortResponse from resource manager

func (*AbortResponse) Descriptor deprecated 

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

Deprecated: Use AbortResponse.ProtoReflect.Descriptor instead.

func (*AbortResponse) ProtoMessage 

func (*AbortResponse) ProtoMessage()

func (*AbortResponse) ProtoReflect 

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

func (*AbortResponse) Reset 

func (x *AbortResponse) Reset()

func (*AbortResponse) String 

func (x *AbortResponse) String() string

type BeginRequest 

type BeginRequest struct {

	// votes for transaction known by resource manager
	Votes *Votes `protobuf:"bytes,1,opt,name=votes,proto3" json:"votes,omitempty"`
	// additional metadata
	Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

BeginRequest for transaction manager

func (*BeginRequest) Descriptor deprecated 

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

Deprecated: Use BeginRequest.ProtoReflect.Descriptor instead.

func (*BeginRequest) GetMeta 

func (x *BeginRequest) GetMeta() *Meta

func (*BeginRequest) GetVotes 

func (x *BeginRequest) GetVotes() *Votes

func (*BeginRequest) ProtoMessage 

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) ProtoReflect 

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

func (*BeginRequest) Reset 

func (x *BeginRequest) Reset()

func (*BeginRequest) String 

func (x *BeginRequest) String() string

type BeginResponse 

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

BeginResponse from transaction manager

func (*BeginResponse) Descriptor deprecated 

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

Deprecated: Use BeginResponse.ProtoReflect.Descriptor instead.

func (*BeginResponse) ProtoMessage 

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) ProtoReflect 

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

func (*BeginResponse) Reset 

func (x *BeginResponse) Reset()

func (*BeginResponse) String 

func (x *BeginResponse) String() string

type CommitRequest 

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

CommitRequest command to resource manager

func (*CommitRequest) Descriptor deprecated 

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

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect 

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

func (*CommitRequest) Reset 

func (x *CommitRequest) Reset()

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type CommitResponse 

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

CommitResponse from resource manager

func (*CommitResponse) Descriptor deprecated 

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

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect 

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

func (*CommitResponse) Reset 

func (x *CommitResponse) Reset()

func (*CommitResponse) String 

func (x *CommitResponse) String() string

type FinishRequest 

type FinishRequest struct {

	// resource manager node identifier
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// additional metadata
	Meta *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

FinishRequest for transaction manager

func (*FinishRequest) Descriptor deprecated 

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

Deprecated: Use FinishRequest.ProtoReflect.Descriptor instead.

func (*FinishRequest) GetMeta 

func (x *FinishRequest) GetMeta() *Meta

func (*FinishRequest) GetNodeId 

func (x *FinishRequest) GetNodeId() string

func (*FinishRequest) ProtoMessage 

func (*FinishRequest) ProtoMessage()

func (*FinishRequest) ProtoReflect 

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

func (*FinishRequest) Reset 

func (x *FinishRequest) Reset()

func (*FinishRequest) String 

func (x *FinishRequest) String() string

type FinishResponse 

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

FinishResponse from transaction manager

func (*FinishResponse) Descriptor deprecated 

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

Deprecated: Use FinishResponse.ProtoReflect.Descriptor instead.

func (*FinishResponse) ProtoMessage 

func (*FinishResponse) ProtoMessage()

func (*FinishResponse) ProtoReflect 

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

func (*FinishResponse) Reset 

func (x *FinishResponse) Reset()

func (*FinishResponse) String 

func (x *FinishResponse) String() string

type ManagerServiceClient 

type ManagerServiceClient interface {
	// Begin transaction
	Begin(ctx context.Context, in *BeginRequest, opts ...grpc.CallOption) (*BeginResponse, error)
	// Finish transaction
	Finish(ctx context.Context, in *FinishRequest, opts ...grpc.CallOption) (*FinishResponse, error)
}

ManagerServiceClient is the client API for ManagerService 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 NewManagerServiceClient 

func NewManagerServiceClient(cc grpc.ClientConnInterface) ManagerServiceClient

type ManagerServiceServer 

type ManagerServiceServer interface {
	// Begin transaction
	Begin(context.Context, *BeginRequest) (*BeginResponse, error)
	// Finish transaction
	Finish(context.Context, *FinishRequest) (*FinishResponse, error)
	// contains filtered or unexported methods
}

ManagerServiceServer is the server API for ManagerService service. All implementations must embed UnimplementedManagerServiceServer for forward compatibility

type Meta 

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

Meta is an optional additional transaction metadata that could be sent by RM and used by TM.

func (*Meta) Descriptor deprecated 

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetMeta 

func (x *Meta) GetMeta() string

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

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

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type ResourceServiceClient 

type ResourceServiceClient interface {
	// Commit transaction command
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	// Abort transaction command
	Abort(ctx context.Context, in *AbortRequest, opts ...grpc.CallOption) (*AbortResponse, error)
}

ResourceServiceClient is the client API for ResourceService 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 NewResourceServiceClient 

func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient

type ResourceServiceServer 

type ResourceServiceServer interface {
	// Commit transaction command
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	// Abort transaction command
	Abort(context.Context, *AbortRequest) (*AbortResponse, error)
	// contains filtered or unexported methods
}

ResourceServiceServer is the server API for ResourceService service. All implementations must embed UnimplementedResourceServiceServer for forward compatibility

type TxID 

type TxID struct {
	TxId string `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	// contains filtered or unexported fields
}

TxID is unique identifier of the transacion

func (*TxID) Descriptor deprecated 

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

Deprecated: Use TxID.ProtoReflect.Descriptor instead.

func (*TxID) GetTxId 

func (x *TxID) GetTxId() string

func (*TxID) ProtoMessage 

func (*TxID) ProtoMessage()

func (*TxID) ProtoReflect 

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

func (*TxID) Reset 

func (x *TxID) Reset()

func (*TxID) String 

func (x *TxID) String() string

type UnimplementedManagerServiceServer 

type UnimplementedManagerServiceServer struct {
}

UnimplementedManagerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedManagerServiceServer) Begin 

func (UnimplementedManagerServiceServer) Begin(context.Context, *BeginRequest) (*BeginResponse, error)

func (UnimplementedManagerServiceServer) Finish 

func (UnimplementedManagerServiceServer) Finish(context.Context, *FinishRequest) (*FinishResponse, error)

type UnimplementedResourceServiceServer 

type UnimplementedResourceServiceServer struct {
}

UnimplementedResourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceServiceServer) Abort 

func (UnimplementedResourceServiceServer) Abort(context.Context, *AbortRequest) (*AbortResponse, error)

func (UnimplementedResourceServiceServer) Commit 

func (UnimplementedResourceServiceServer) Commit(context.Context, *CommitRequest) (*CommitResponse, error)

type UnsafeManagerServiceServer 

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

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

type UnsafeResourceServiceServer 

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

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

type Vote 

type Vote struct {
	Vote uint32 `protobuf:"varint,1,opt,name=vote,proto3" json:"vote,omitempty"`
	// contains filtered or unexported fields
}

Vote of RM

func (*Vote) Descriptor deprecated 

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

Deprecated: Use Vote.ProtoReflect.Descriptor instead.

func (*Vote) GetVote 

func (x *Vote) GetVote() uint32

func (*Vote) ProtoMessage 

func (*Vote) ProtoMessage()

func (*Vote) ProtoReflect 

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

func (*Vote) Reset 

func (x *Vote) Reset()

func (*Vote) String 

func (x *Vote) String() string

type Votes 

type Votes struct {
	Votes map[string]*Vote `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

Votes is a map of votes by node

func (*Votes) Descriptor deprecated 

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

Deprecated: Use Votes.ProtoReflect.Descriptor instead.

func (*Votes) GetVotes 

func (x *Votes) GetVotes() map[string]*Vote

func (*Votes) ProtoMessage 

func (*Votes) ProtoMessage()

func (*Votes) ProtoReflect 

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

func (*Votes) Reset 

func (x *Votes) Reset()

func (*Votes) String 

func (x *Votes) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.