Documentation ¶
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type DeleteAllRequest
- func (*DeleteAllRequest) Descriptor() ([]byte, []int)
- func (m *DeleteAllRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteAllRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteAllRequest) ProtoMessage()
- func (m *DeleteAllRequest) Reset()
- func (m *DeleteAllRequest) Size() (n int)
- func (m *DeleteAllRequest) String() string
- func (m *DeleteAllRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteAllRequest) XXX_DiscardUnknown()
- func (m *DeleteAllRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteAllRequest) XXX_Merge(src proto.Message)
- func (m *DeleteAllRequest) XXX_Size() int
- func (m *DeleteAllRequest) XXX_Unmarshal(b []byte) error
- type DeleteTransactionRequest
- func (*DeleteTransactionRequest) Descriptor() ([]byte, []int)
- func (m *DeleteTransactionRequest) GetTransaction() *Transaction
- func (m *DeleteTransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteTransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteTransactionRequest) ProtoMessage()
- func (m *DeleteTransactionRequest) Reset()
- func (m *DeleteTransactionRequest) Size() (n int)
- func (m *DeleteTransactionRequest) String() string
- func (m *DeleteTransactionRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteTransactionRequest) XXX_DiscardUnknown()
- func (m *DeleteTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteTransactionRequest) XXX_Merge(src proto.Message)
- func (m *DeleteTransactionRequest) XXX_Size() int
- func (m *DeleteTransactionRequest) XXX_Unmarshal(b []byte) error
- type FinishTransactionRequest
- func (*FinishTransactionRequest) Descriptor() ([]byte, []int)
- func (m *FinishTransactionRequest) GetTransaction() *Transaction
- func (m *FinishTransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *FinishTransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*FinishTransactionRequest) ProtoMessage()
- func (m *FinishTransactionRequest) Reset()
- func (m *FinishTransactionRequest) Size() (n int)
- func (m *FinishTransactionRequest) String() string
- func (m *FinishTransactionRequest) Unmarshal(dAtA []byte) error
- func (m *FinishTransactionRequest) XXX_DiscardUnknown()
- func (m *FinishTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FinishTransactionRequest) XXX_Merge(src proto.Message)
- func (m *FinishTransactionRequest) XXX_Size() int
- func (m *FinishTransactionRequest) XXX_Unmarshal(b []byte) error
- type InspectTransactionRequest
- func (*InspectTransactionRequest) Descriptor() ([]byte, []int)
- func (m *InspectTransactionRequest) GetTransaction() *Transaction
- func (m *InspectTransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *InspectTransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*InspectTransactionRequest) ProtoMessage()
- func (m *InspectTransactionRequest) Reset()
- func (m *InspectTransactionRequest) Size() (n int)
- func (m *InspectTransactionRequest) String() string
- func (m *InspectTransactionRequest) Unmarshal(dAtA []byte) error
- func (m *InspectTransactionRequest) XXX_DiscardUnknown()
- func (m *InspectTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectTransactionRequest) XXX_Merge(src proto.Message)
- func (m *InspectTransactionRequest) XXX_Size() int
- func (m *InspectTransactionRequest) XXX_Unmarshal(b []byte) error
- type ListTransactionRequest
- func (*ListTransactionRequest) Descriptor() ([]byte, []int)
- func (m *ListTransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *ListTransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ListTransactionRequest) ProtoMessage()
- func (m *ListTransactionRequest) Reset()
- func (m *ListTransactionRequest) Size() (n int)
- func (m *ListTransactionRequest) String() string
- func (m *ListTransactionRequest) Unmarshal(dAtA []byte) error
- func (m *ListTransactionRequest) XXX_DiscardUnknown()
- func (m *ListTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListTransactionRequest) XXX_Merge(src proto.Message)
- func (m *ListTransactionRequest) XXX_Size() int
- func (m *ListTransactionRequest) XXX_Unmarshal(b []byte) error
- type StartTransactionRequest
- func (*StartTransactionRequest) Descriptor() ([]byte, []int)
- func (m *StartTransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *StartTransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*StartTransactionRequest) ProtoMessage()
- func (m *StartTransactionRequest) Reset()
- func (m *StartTransactionRequest) Size() (n int)
- func (m *StartTransactionRequest) String() string
- func (m *StartTransactionRequest) Unmarshal(dAtA []byte) error
- func (m *StartTransactionRequest) XXX_DiscardUnknown()
- func (m *StartTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartTransactionRequest) XXX_Merge(src proto.Message)
- func (m *StartTransactionRequest) XXX_Size() int
- func (m *StartTransactionRequest) XXX_Unmarshal(b []byte) error
- type Transaction
- func (*Transaction) Descriptor() ([]byte, []int)
- func (m *Transaction) GetID() string
- func (m *Transaction) Marshal() (dAtA []byte, err error)
- func (m *Transaction) MarshalTo(dAtA []byte) (int, error)
- func (*Transaction) ProtoMessage()
- func (m *Transaction) Reset()
- func (m *Transaction) Size() (n int)
- func (m *Transaction) String() string
- func (m *Transaction) Unmarshal(dAtA []byte) error
- func (m *Transaction) XXX_DiscardUnknown()
- func (m *Transaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Transaction) XXX_Merge(src proto.Message)
- func (m *Transaction) XXX_Size() int
- func (m *Transaction) XXX_Unmarshal(b []byte) error
- type TransactionInfo
- func (*TransactionInfo) Descriptor() ([]byte, []int)
- func (m *TransactionInfo) GetRequests() []*TransactionRequest
- func (m *TransactionInfo) GetResponses() []*TransactionResponse
- func (m *TransactionInfo) GetStarted() *types.Timestamp
- func (m *TransactionInfo) GetTransaction() *Transaction
- func (m *TransactionInfo) Marshal() (dAtA []byte, err error)
- func (m *TransactionInfo) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionInfo) ProtoMessage()
- func (m *TransactionInfo) Reset()
- func (m *TransactionInfo) Size() (n int)
- func (m *TransactionInfo) String() string
- func (m *TransactionInfo) Unmarshal(dAtA []byte) error
- func (m *TransactionInfo) XXX_DiscardUnknown()
- func (m *TransactionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransactionInfo) XXX_Merge(src proto.Message)
- func (m *TransactionInfo) XXX_Size() int
- func (m *TransactionInfo) XXX_Unmarshal(b []byte) error
- type TransactionInfos
- func (*TransactionInfos) Descriptor() ([]byte, []int)
- func (m *TransactionInfos) GetTransactionInfo() []*TransactionInfo
- func (m *TransactionInfos) Marshal() (dAtA []byte, err error)
- func (m *TransactionInfos) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionInfos) ProtoMessage()
- func (m *TransactionInfos) Reset()
- func (m *TransactionInfos) Size() (n int)
- func (m *TransactionInfos) String() string
- func (m *TransactionInfos) Unmarshal(dAtA []byte) error
- func (m *TransactionInfos) XXX_DiscardUnknown()
- func (m *TransactionInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransactionInfos) XXX_Merge(src proto.Message)
- func (m *TransactionInfos) XXX_Size() int
- func (m *TransactionInfos) XXX_Unmarshal(b []byte) error
- type TransactionRequest
- func (*TransactionRequest) Descriptor() ([]byte, []int)
- func (m *TransactionRequest) GetCreateBranch() *pfs.CreateBranchRequest
- func (m *TransactionRequest) GetCreateRepo() *pfs.CreateRepoRequest
- func (m *TransactionRequest) GetDeleteAll() *DeleteAllRequest
- func (m *TransactionRequest) GetDeleteBranch() *pfs.DeleteBranchRequest
- func (m *TransactionRequest) GetDeleteCommit() *pfs.DeleteCommitRequest
- func (m *TransactionRequest) GetDeleteRepo() *pfs.DeleteRepoRequest
- func (m *TransactionRequest) GetFinishCommit() *pfs.FinishCommitRequest
- func (m *TransactionRequest) GetStartCommit() *pfs.StartCommitRequest
- func (m *TransactionRequest) Marshal() (dAtA []byte, err error)
- func (m *TransactionRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionRequest) ProtoMessage()
- func (m *TransactionRequest) Reset()
- func (m *TransactionRequest) Size() (n int)
- func (m *TransactionRequest) String() string
- func (m *TransactionRequest) Unmarshal(dAtA []byte) error
- func (m *TransactionRequest) XXX_DiscardUnknown()
- func (m *TransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransactionRequest) XXX_Merge(src proto.Message)
- func (m *TransactionRequest) XXX_Size() int
- func (m *TransactionRequest) XXX_Unmarshal(b []byte) error
- type TransactionResponse
- func (*TransactionResponse) Descriptor() ([]byte, []int)
- func (m *TransactionResponse) GetCommit() *pfs.Commit
- func (m *TransactionResponse) Marshal() (dAtA []byte, err error)
- func (m *TransactionResponse) MarshalTo(dAtA []byte) (int, error)
- func (*TransactionResponse) ProtoMessage()
- func (m *TransactionResponse) Reset()
- func (m *TransactionResponse) Size() (n int)
- func (m *TransactionResponse) String() string
- func (m *TransactionResponse) Unmarshal(dAtA []byte) error
- func (m *TransactionResponse) XXX_DiscardUnknown()
- func (m *TransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransactionResponse) XXX_Merge(src proto.Message)
- func (m *TransactionResponse) XXX_Size() int
- func (m *TransactionResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedAPIServer
- func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *DeleteAllRequest) (*types.Empty, error)
- func (*UnimplementedAPIServer) DeleteTransaction(ctx context.Context, req *DeleteTransactionRequest) (*types.Empty, error)
- func (*UnimplementedAPIServer) FinishTransaction(ctx context.Context, req *FinishTransactionRequest) (*TransactionInfo, error)
- func (*UnimplementedAPIServer) InspectTransaction(ctx context.Context, req *InspectTransactionRequest) (*TransactionInfo, error)
- func (*UnimplementedAPIServer) ListTransaction(ctx context.Context, req *ListTransactionRequest) (*TransactionInfos, error)
- func (*UnimplementedAPIServer) StartTransaction(ctx context.Context, req *StartTransactionRequest) (*Transaction, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthTransaction = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTransaction = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface { // Transaction rpcs StartTransaction(ctx context.Context, in *StartTransactionRequest, opts ...grpc.CallOption) (*Transaction, error) InspectTransaction(ctx context.Context, in *InspectTransactionRequest, opts ...grpc.CallOption) (*TransactionInfo, error) DeleteTransaction(ctx context.Context, in *DeleteTransactionRequest, opts ...grpc.CallOption) (*types.Empty, error) ListTransaction(ctx context.Context, in *ListTransactionRequest, opts ...grpc.CallOption) (*TransactionInfos, error) FinishTransaction(ctx context.Context, in *FinishTransactionRequest, opts ...grpc.CallOption) (*TransactionInfo, error) DeleteAll(ctx context.Context, in *DeleteAllRequest, opts ...grpc.CallOption) (*types.Empty, error) }
APIClient is the client API for API service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface { // Transaction rpcs StartTransaction(context.Context, *StartTransactionRequest) (*Transaction, error) InspectTransaction(context.Context, *InspectTransactionRequest) (*TransactionInfo, error) DeleteTransaction(context.Context, *DeleteTransactionRequest) (*types.Empty, error) ListTransaction(context.Context, *ListTransactionRequest) (*TransactionInfos, error) FinishTransaction(context.Context, *FinishTransactionRequest) (*TransactionInfo, error) DeleteAll(context.Context, *DeleteAllRequest) (*types.Empty, error) }
APIServer is the server API for API service.
type DeleteAllRequest ¶
type DeleteAllRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteAllRequest) Descriptor ¶
func (*DeleteAllRequest) Descriptor() ([]byte, []int)
func (*DeleteAllRequest) Marshal ¶
func (m *DeleteAllRequest) Marshal() (dAtA []byte, err error)
func (*DeleteAllRequest) ProtoMessage ¶
func (*DeleteAllRequest) ProtoMessage()
func (*DeleteAllRequest) Reset ¶
func (m *DeleteAllRequest) Reset()
func (*DeleteAllRequest) Size ¶
func (m *DeleteAllRequest) Size() (n int)
func (*DeleteAllRequest) String ¶
func (m *DeleteAllRequest) String() string
func (*DeleteAllRequest) Unmarshal ¶
func (m *DeleteAllRequest) Unmarshal(dAtA []byte) error
func (*DeleteAllRequest) XXX_DiscardUnknown ¶
func (m *DeleteAllRequest) XXX_DiscardUnknown()
func (*DeleteAllRequest) XXX_Marshal ¶
func (m *DeleteAllRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteAllRequest) XXX_Merge ¶
func (m *DeleteAllRequest) XXX_Merge(src proto.Message)
func (*DeleteAllRequest) XXX_Size ¶
func (m *DeleteAllRequest) XXX_Size() int
func (*DeleteAllRequest) XXX_Unmarshal ¶
func (m *DeleteAllRequest) XXX_Unmarshal(b []byte) error
type DeleteTransactionRequest ¶
type DeleteTransactionRequest struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteTransactionRequest) Descriptor ¶
func (*DeleteTransactionRequest) Descriptor() ([]byte, []int)
func (*DeleteTransactionRequest) GetTransaction ¶
func (m *DeleteTransactionRequest) GetTransaction() *Transaction
func (*DeleteTransactionRequest) Marshal ¶
func (m *DeleteTransactionRequest) Marshal() (dAtA []byte, err error)
func (*DeleteTransactionRequest) MarshalTo ¶
func (m *DeleteTransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteTransactionRequest) ProtoMessage ¶
func (*DeleteTransactionRequest) ProtoMessage()
func (*DeleteTransactionRequest) Reset ¶
func (m *DeleteTransactionRequest) Reset()
func (*DeleteTransactionRequest) Size ¶
func (m *DeleteTransactionRequest) Size() (n int)
func (*DeleteTransactionRequest) String ¶
func (m *DeleteTransactionRequest) String() string
func (*DeleteTransactionRequest) Unmarshal ¶
func (m *DeleteTransactionRequest) Unmarshal(dAtA []byte) error
func (*DeleteTransactionRequest) XXX_DiscardUnknown ¶
func (m *DeleteTransactionRequest) XXX_DiscardUnknown()
func (*DeleteTransactionRequest) XXX_Marshal ¶
func (m *DeleteTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteTransactionRequest) XXX_Merge ¶
func (m *DeleteTransactionRequest) XXX_Merge(src proto.Message)
func (*DeleteTransactionRequest) XXX_Size ¶
func (m *DeleteTransactionRequest) XXX_Size() int
func (*DeleteTransactionRequest) XXX_Unmarshal ¶
func (m *DeleteTransactionRequest) XXX_Unmarshal(b []byte) error
type FinishTransactionRequest ¶
type FinishTransactionRequest struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FinishTransactionRequest) Descriptor ¶
func (*FinishTransactionRequest) Descriptor() ([]byte, []int)
func (*FinishTransactionRequest) GetTransaction ¶
func (m *FinishTransactionRequest) GetTransaction() *Transaction
func (*FinishTransactionRequest) Marshal ¶
func (m *FinishTransactionRequest) Marshal() (dAtA []byte, err error)
func (*FinishTransactionRequest) MarshalTo ¶
func (m *FinishTransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*FinishTransactionRequest) ProtoMessage ¶
func (*FinishTransactionRequest) ProtoMessage()
func (*FinishTransactionRequest) Reset ¶
func (m *FinishTransactionRequest) Reset()
func (*FinishTransactionRequest) Size ¶
func (m *FinishTransactionRequest) Size() (n int)
func (*FinishTransactionRequest) String ¶
func (m *FinishTransactionRequest) String() string
func (*FinishTransactionRequest) Unmarshal ¶
func (m *FinishTransactionRequest) Unmarshal(dAtA []byte) error
func (*FinishTransactionRequest) XXX_DiscardUnknown ¶
func (m *FinishTransactionRequest) XXX_DiscardUnknown()
func (*FinishTransactionRequest) XXX_Marshal ¶
func (m *FinishTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FinishTransactionRequest) XXX_Merge ¶
func (m *FinishTransactionRequest) XXX_Merge(src proto.Message)
func (*FinishTransactionRequest) XXX_Size ¶
func (m *FinishTransactionRequest) XXX_Size() int
func (*FinishTransactionRequest) XXX_Unmarshal ¶
func (m *FinishTransactionRequest) XXX_Unmarshal(b []byte) error
type InspectTransactionRequest ¶
type InspectTransactionRequest struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InspectTransactionRequest) Descriptor ¶
func (*InspectTransactionRequest) Descriptor() ([]byte, []int)
func (*InspectTransactionRequest) GetTransaction ¶
func (m *InspectTransactionRequest) GetTransaction() *Transaction
func (*InspectTransactionRequest) Marshal ¶
func (m *InspectTransactionRequest) Marshal() (dAtA []byte, err error)
func (*InspectTransactionRequest) MarshalTo ¶
func (m *InspectTransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*InspectTransactionRequest) ProtoMessage ¶
func (*InspectTransactionRequest) ProtoMessage()
func (*InspectTransactionRequest) Reset ¶
func (m *InspectTransactionRequest) Reset()
func (*InspectTransactionRequest) Size ¶
func (m *InspectTransactionRequest) Size() (n int)
func (*InspectTransactionRequest) String ¶
func (m *InspectTransactionRequest) String() string
func (*InspectTransactionRequest) Unmarshal ¶
func (m *InspectTransactionRequest) Unmarshal(dAtA []byte) error
func (*InspectTransactionRequest) XXX_DiscardUnknown ¶
func (m *InspectTransactionRequest) XXX_DiscardUnknown()
func (*InspectTransactionRequest) XXX_Marshal ¶
func (m *InspectTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InspectTransactionRequest) XXX_Merge ¶
func (m *InspectTransactionRequest) XXX_Merge(src proto.Message)
func (*InspectTransactionRequest) XXX_Size ¶
func (m *InspectTransactionRequest) XXX_Size() int
func (*InspectTransactionRequest) XXX_Unmarshal ¶
func (m *InspectTransactionRequest) XXX_Unmarshal(b []byte) error
type ListTransactionRequest ¶
type ListTransactionRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListTransactionRequest) Descriptor ¶
func (*ListTransactionRequest) Descriptor() ([]byte, []int)
func (*ListTransactionRequest) Marshal ¶
func (m *ListTransactionRequest) Marshal() (dAtA []byte, err error)
func (*ListTransactionRequest) MarshalTo ¶
func (m *ListTransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListTransactionRequest) ProtoMessage ¶
func (*ListTransactionRequest) ProtoMessage()
func (*ListTransactionRequest) Reset ¶
func (m *ListTransactionRequest) Reset()
func (*ListTransactionRequest) Size ¶
func (m *ListTransactionRequest) Size() (n int)
func (*ListTransactionRequest) String ¶
func (m *ListTransactionRequest) String() string
func (*ListTransactionRequest) Unmarshal ¶
func (m *ListTransactionRequest) Unmarshal(dAtA []byte) error
func (*ListTransactionRequest) XXX_DiscardUnknown ¶
func (m *ListTransactionRequest) XXX_DiscardUnknown()
func (*ListTransactionRequest) XXX_Marshal ¶
func (m *ListTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTransactionRequest) XXX_Merge ¶
func (m *ListTransactionRequest) XXX_Merge(src proto.Message)
func (*ListTransactionRequest) XXX_Size ¶
func (m *ListTransactionRequest) XXX_Size() int
func (*ListTransactionRequest) XXX_Unmarshal ¶
func (m *ListTransactionRequest) XXX_Unmarshal(b []byte) error
type StartTransactionRequest ¶
type StartTransactionRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StartTransactionRequest) Descriptor ¶
func (*StartTransactionRequest) Descriptor() ([]byte, []int)
func (*StartTransactionRequest) Marshal ¶
func (m *StartTransactionRequest) Marshal() (dAtA []byte, err error)
func (*StartTransactionRequest) MarshalTo ¶
func (m *StartTransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*StartTransactionRequest) ProtoMessage ¶
func (*StartTransactionRequest) ProtoMessage()
func (*StartTransactionRequest) Reset ¶
func (m *StartTransactionRequest) Reset()
func (*StartTransactionRequest) Size ¶
func (m *StartTransactionRequest) Size() (n int)
func (*StartTransactionRequest) String ¶
func (m *StartTransactionRequest) String() string
func (*StartTransactionRequest) Unmarshal ¶
func (m *StartTransactionRequest) Unmarshal(dAtA []byte) error
func (*StartTransactionRequest) XXX_DiscardUnknown ¶
func (m *StartTransactionRequest) XXX_DiscardUnknown()
func (*StartTransactionRequest) XXX_Marshal ¶
func (m *StartTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartTransactionRequest) XXX_Merge ¶
func (m *StartTransactionRequest) XXX_Merge(src proto.Message)
func (*StartTransactionRequest) XXX_Size ¶
func (m *StartTransactionRequest) XXX_Size() int
func (*StartTransactionRequest) XXX_Unmarshal ¶
func (m *StartTransactionRequest) XXX_Unmarshal(b []byte) error
type Transaction ¶
type Transaction struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Transaction) Descriptor ¶
func (*Transaction) Descriptor() ([]byte, []int)
func (*Transaction) GetID ¶
func (m *Transaction) GetID() string
func (*Transaction) Marshal ¶
func (m *Transaction) Marshal() (dAtA []byte, err error)
func (*Transaction) ProtoMessage ¶
func (*Transaction) ProtoMessage()
func (*Transaction) Reset ¶
func (m *Transaction) Reset()
func (*Transaction) Size ¶
func (m *Transaction) Size() (n int)
func (*Transaction) String ¶
func (m *Transaction) String() string
func (*Transaction) Unmarshal ¶
func (m *Transaction) Unmarshal(dAtA []byte) error
func (*Transaction) XXX_DiscardUnknown ¶
func (m *Transaction) XXX_DiscardUnknown()
func (*Transaction) XXX_Marshal ¶
func (m *Transaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Transaction) XXX_Merge ¶
func (m *Transaction) XXX_Merge(src proto.Message)
func (*Transaction) XXX_Size ¶
func (m *Transaction) XXX_Size() int
func (*Transaction) XXX_Unmarshal ¶
func (m *Transaction) XXX_Unmarshal(b []byte) error
type TransactionInfo ¶
type TransactionInfo struct { Transaction *Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` Requests []*TransactionRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"` Responses []*TransactionResponse `protobuf:"bytes,3,rep,name=responses,proto3" json:"responses,omitempty"` Started *types.Timestamp `protobuf:"bytes,4,opt,name=started,proto3" json:"started,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TransactionInfo) Descriptor ¶
func (*TransactionInfo) Descriptor() ([]byte, []int)
func (*TransactionInfo) GetRequests ¶
func (m *TransactionInfo) GetRequests() []*TransactionRequest
func (*TransactionInfo) GetResponses ¶
func (m *TransactionInfo) GetResponses() []*TransactionResponse
func (*TransactionInfo) GetStarted ¶
func (m *TransactionInfo) GetStarted() *types.Timestamp
func (*TransactionInfo) GetTransaction ¶
func (m *TransactionInfo) GetTransaction() *Transaction
func (*TransactionInfo) Marshal ¶
func (m *TransactionInfo) Marshal() (dAtA []byte, err error)
func (*TransactionInfo) ProtoMessage ¶
func (*TransactionInfo) ProtoMessage()
func (*TransactionInfo) Reset ¶
func (m *TransactionInfo) Reset()
func (*TransactionInfo) Size ¶
func (m *TransactionInfo) Size() (n int)
func (*TransactionInfo) String ¶
func (m *TransactionInfo) String() string
func (*TransactionInfo) Unmarshal ¶
func (m *TransactionInfo) Unmarshal(dAtA []byte) error
func (*TransactionInfo) XXX_DiscardUnknown ¶
func (m *TransactionInfo) XXX_DiscardUnknown()
func (*TransactionInfo) XXX_Marshal ¶
func (m *TransactionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransactionInfo) XXX_Merge ¶
func (m *TransactionInfo) XXX_Merge(src proto.Message)
func (*TransactionInfo) XXX_Size ¶
func (m *TransactionInfo) XXX_Size() int
func (*TransactionInfo) XXX_Unmarshal ¶
func (m *TransactionInfo) XXX_Unmarshal(b []byte) error
type TransactionInfos ¶
type TransactionInfos struct { TransactionInfo []*TransactionInfo `protobuf:"bytes,1,rep,name=transaction_info,json=transactionInfo,proto3" json:"transaction_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TransactionInfos) Descriptor ¶
func (*TransactionInfos) Descriptor() ([]byte, []int)
func (*TransactionInfos) GetTransactionInfo ¶
func (m *TransactionInfos) GetTransactionInfo() []*TransactionInfo
func (*TransactionInfos) Marshal ¶
func (m *TransactionInfos) Marshal() (dAtA []byte, err error)
func (*TransactionInfos) ProtoMessage ¶
func (*TransactionInfos) ProtoMessage()
func (*TransactionInfos) Reset ¶
func (m *TransactionInfos) Reset()
func (*TransactionInfos) Size ¶
func (m *TransactionInfos) Size() (n int)
func (*TransactionInfos) String ¶
func (m *TransactionInfos) String() string
func (*TransactionInfos) Unmarshal ¶
func (m *TransactionInfos) Unmarshal(dAtA []byte) error
func (*TransactionInfos) XXX_DiscardUnknown ¶
func (m *TransactionInfos) XXX_DiscardUnknown()
func (*TransactionInfos) XXX_Marshal ¶
func (m *TransactionInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransactionInfos) XXX_Merge ¶
func (m *TransactionInfos) XXX_Merge(src proto.Message)
func (*TransactionInfos) XXX_Size ¶
func (m *TransactionInfos) XXX_Size() int
func (*TransactionInfos) XXX_Unmarshal ¶
func (m *TransactionInfos) XXX_Unmarshal(b []byte) error
type TransactionRequest ¶
type TransactionRequest struct { // Exactly one of these fields should be set CreateRepo *pfs.CreateRepoRequest `protobuf:"bytes,1,opt,name=create_repo,json=createRepo,proto3" json:"create_repo,omitempty"` DeleteRepo *pfs.DeleteRepoRequest `protobuf:"bytes,2,opt,name=delete_repo,json=deleteRepo,proto3" json:"delete_repo,omitempty"` StartCommit *pfs.StartCommitRequest `protobuf:"bytes,3,opt,name=start_commit,json=startCommit,proto3" json:"start_commit,omitempty"` FinishCommit *pfs.FinishCommitRequest `protobuf:"bytes,4,opt,name=finish_commit,json=finishCommit,proto3" json:"finish_commit,omitempty"` DeleteCommit *pfs.DeleteCommitRequest `protobuf:"bytes,5,opt,name=delete_commit,json=deleteCommit,proto3" json:"delete_commit,omitempty"` CreateBranch *pfs.CreateBranchRequest `protobuf:"bytes,6,opt,name=create_branch,json=createBranch,proto3" json:"create_branch,omitempty"` DeleteBranch *pfs.DeleteBranchRequest `protobuf:"bytes,7,opt,name=delete_branch,json=deleteBranch,proto3" json:"delete_branch,omitempty"` DeleteAll *DeleteAllRequest `protobuf:"bytes,10,opt,name=delete_all,json=deleteAll,proto3" json:"delete_all,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TransactionRequest) Descriptor ¶
func (*TransactionRequest) Descriptor() ([]byte, []int)
func (*TransactionRequest) GetCreateBranch ¶
func (m *TransactionRequest) GetCreateBranch() *pfs.CreateBranchRequest
func (*TransactionRequest) GetCreateRepo ¶
func (m *TransactionRequest) GetCreateRepo() *pfs.CreateRepoRequest
func (*TransactionRequest) GetDeleteAll ¶
func (m *TransactionRequest) GetDeleteAll() *DeleteAllRequest
func (*TransactionRequest) GetDeleteBranch ¶
func (m *TransactionRequest) GetDeleteBranch() *pfs.DeleteBranchRequest
func (*TransactionRequest) GetDeleteCommit ¶
func (m *TransactionRequest) GetDeleteCommit() *pfs.DeleteCommitRequest
func (*TransactionRequest) GetDeleteRepo ¶
func (m *TransactionRequest) GetDeleteRepo() *pfs.DeleteRepoRequest
func (*TransactionRequest) GetFinishCommit ¶
func (m *TransactionRequest) GetFinishCommit() *pfs.FinishCommitRequest
func (*TransactionRequest) GetStartCommit ¶
func (m *TransactionRequest) GetStartCommit() *pfs.StartCommitRequest
func (*TransactionRequest) Marshal ¶
func (m *TransactionRequest) Marshal() (dAtA []byte, err error)
func (*TransactionRequest) MarshalTo ¶
func (m *TransactionRequest) MarshalTo(dAtA []byte) (int, error)
func (*TransactionRequest) ProtoMessage ¶
func (*TransactionRequest) ProtoMessage()
func (*TransactionRequest) Reset ¶
func (m *TransactionRequest) Reset()
func (*TransactionRequest) Size ¶
func (m *TransactionRequest) Size() (n int)
func (*TransactionRequest) String ¶
func (m *TransactionRequest) String() string
func (*TransactionRequest) Unmarshal ¶
func (m *TransactionRequest) Unmarshal(dAtA []byte) error
func (*TransactionRequest) XXX_DiscardUnknown ¶
func (m *TransactionRequest) XXX_DiscardUnknown()
func (*TransactionRequest) XXX_Marshal ¶
func (m *TransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransactionRequest) XXX_Merge ¶
func (m *TransactionRequest) XXX_Merge(src proto.Message)
func (*TransactionRequest) XXX_Size ¶
func (m *TransactionRequest) XXX_Size() int
func (*TransactionRequest) XXX_Unmarshal ¶
func (m *TransactionRequest) XXX_Unmarshal(b []byte) error
type TransactionResponse ¶
type TransactionResponse struct { // At most, one of these fields should be set (most responses are empty) Commit *pfs.Commit `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TransactionResponse) Descriptor ¶
func (*TransactionResponse) Descriptor() ([]byte, []int)
func (*TransactionResponse) GetCommit ¶
func (m *TransactionResponse) GetCommit() *pfs.Commit
func (*TransactionResponse) Marshal ¶
func (m *TransactionResponse) Marshal() (dAtA []byte, err error)
func (*TransactionResponse) MarshalTo ¶
func (m *TransactionResponse) MarshalTo(dAtA []byte) (int, error)
func (*TransactionResponse) ProtoMessage ¶
func (*TransactionResponse) ProtoMessage()
func (*TransactionResponse) Reset ¶
func (m *TransactionResponse) Reset()
func (*TransactionResponse) Size ¶
func (m *TransactionResponse) Size() (n int)
func (*TransactionResponse) String ¶
func (m *TransactionResponse) String() string
func (*TransactionResponse) Unmarshal ¶
func (m *TransactionResponse) Unmarshal(dAtA []byte) error
func (*TransactionResponse) XXX_DiscardUnknown ¶
func (m *TransactionResponse) XXX_DiscardUnknown()
func (*TransactionResponse) XXX_Marshal ¶
func (m *TransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransactionResponse) XXX_Merge ¶
func (m *TransactionResponse) XXX_Merge(src proto.Message)
func (*TransactionResponse) XXX_Size ¶
func (m *TransactionResponse) XXX_Size() int
func (*TransactionResponse) XXX_Unmarshal ¶
func (m *TransactionResponse) XXX_Unmarshal(b []byte) error
type UnimplementedAPIServer ¶
type UnimplementedAPIServer struct { }
UnimplementedAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedAPIServer) DeleteAll ¶
func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *DeleteAllRequest) (*types.Empty, error)
func (*UnimplementedAPIServer) DeleteTransaction ¶
func (*UnimplementedAPIServer) DeleteTransaction(ctx context.Context, req *DeleteTransactionRequest) (*types.Empty, error)
func (*UnimplementedAPIServer) FinishTransaction ¶
func (*UnimplementedAPIServer) FinishTransaction(ctx context.Context, req *FinishTransactionRequest) (*TransactionInfo, error)
func (*UnimplementedAPIServer) InspectTransaction ¶
func (*UnimplementedAPIServer) InspectTransaction(ctx context.Context, req *InspectTransactionRequest) (*TransactionInfo, error)
func (*UnimplementedAPIServer) ListTransaction ¶
func (*UnimplementedAPIServer) ListTransaction(ctx context.Context, req *ListTransactionRequest) (*TransactionInfos, error)
func (*UnimplementedAPIServer) StartTransaction ¶
func (*UnimplementedAPIServer) StartTransaction(ctx context.Context, req *StartTransactionRequest) (*Transaction, error)
Click to show internal directories.
Click to hide internal directories.