pachyderm: github.com/pachyderm/pachyderm/src/client/transaction Index | Files

package transaction

import "github.com/pachyderm/pachyderm/src/client/transaction"

Index

Package Files

transaction.pb.go

Variables

var (
    ErrInvalidLengthTransaction = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowTransaction   = fmt.Errorf("proto: integer overflow")
)

func RegisterAPIServer Uses

func RegisterAPIServer(s *grpc.Server, srv APIServer)

type APIClient Uses

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 Uses

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer Uses

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 Uses

type DeleteAllRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*DeleteAllRequest) Descriptor Uses

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

func (*DeleteAllRequest) Marshal Uses

func (m *DeleteAllRequest) Marshal() (dAtA []byte, err error)

func (*DeleteAllRequest) MarshalTo Uses

func (m *DeleteAllRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteAllRequest) MarshalToSizedBuffer Uses

func (m *DeleteAllRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteAllRequest) ProtoMessage Uses

func (*DeleteAllRequest) ProtoMessage()

func (*DeleteAllRequest) Reset Uses

func (m *DeleteAllRequest) Reset()

func (*DeleteAllRequest) Size Uses

func (m *DeleteAllRequest) Size() (n int)

func (*DeleteAllRequest) String Uses

func (m *DeleteAllRequest) String() string

func (*DeleteAllRequest) Unmarshal Uses

func (m *DeleteAllRequest) Unmarshal(dAtA []byte) error

func (*DeleteAllRequest) XXX_DiscardUnknown Uses

func (m *DeleteAllRequest) XXX_DiscardUnknown()

func (*DeleteAllRequest) XXX_Marshal Uses

func (m *DeleteAllRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteAllRequest) XXX_Merge Uses

func (m *DeleteAllRequest) XXX_Merge(src proto.Message)

func (*DeleteAllRequest) XXX_Size Uses

func (m *DeleteAllRequest) XXX_Size() int

func (*DeleteAllRequest) XXX_Unmarshal Uses

func (m *DeleteAllRequest) XXX_Unmarshal(b []byte) error

type DeleteTransactionRequest Uses

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 Uses

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

func (*DeleteTransactionRequest) GetTransaction Uses

func (m *DeleteTransactionRequest) GetTransaction() *Transaction

func (*DeleteTransactionRequest) Marshal Uses

func (m *DeleteTransactionRequest) Marshal() (dAtA []byte, err error)

func (*DeleteTransactionRequest) MarshalTo Uses

func (m *DeleteTransactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteTransactionRequest) MarshalToSizedBuffer Uses

func (m *DeleteTransactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteTransactionRequest) ProtoMessage Uses

func (*DeleteTransactionRequest) ProtoMessage()

func (*DeleteTransactionRequest) Reset Uses

func (m *DeleteTransactionRequest) Reset()

func (*DeleteTransactionRequest) Size Uses

func (m *DeleteTransactionRequest) Size() (n int)

func (*DeleteTransactionRequest) String Uses

func (m *DeleteTransactionRequest) String() string

func (*DeleteTransactionRequest) Unmarshal Uses

func (m *DeleteTransactionRequest) Unmarshal(dAtA []byte) error

func (*DeleteTransactionRequest) XXX_DiscardUnknown Uses

func (m *DeleteTransactionRequest) XXX_DiscardUnknown()

func (*DeleteTransactionRequest) XXX_Marshal Uses

func (m *DeleteTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTransactionRequest) XXX_Merge Uses

func (m *DeleteTransactionRequest) XXX_Merge(src proto.Message)

func (*DeleteTransactionRequest) XXX_Size Uses

func (m *DeleteTransactionRequest) XXX_Size() int

func (*DeleteTransactionRequest) XXX_Unmarshal Uses

func (m *DeleteTransactionRequest) XXX_Unmarshal(b []byte) error

type FinishTransactionRequest Uses

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 Uses

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

func (*FinishTransactionRequest) GetTransaction Uses

func (m *FinishTransactionRequest) GetTransaction() *Transaction

func (*FinishTransactionRequest) Marshal Uses

func (m *FinishTransactionRequest) Marshal() (dAtA []byte, err error)

func (*FinishTransactionRequest) MarshalTo Uses

func (m *FinishTransactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*FinishTransactionRequest) MarshalToSizedBuffer Uses

func (m *FinishTransactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FinishTransactionRequest) ProtoMessage Uses

func (*FinishTransactionRequest) ProtoMessage()

func (*FinishTransactionRequest) Reset Uses

func (m *FinishTransactionRequest) Reset()

func (*FinishTransactionRequest) Size Uses

func (m *FinishTransactionRequest) Size() (n int)

func (*FinishTransactionRequest) String Uses

func (m *FinishTransactionRequest) String() string

func (*FinishTransactionRequest) Unmarshal Uses

func (m *FinishTransactionRequest) Unmarshal(dAtA []byte) error

func (*FinishTransactionRequest) XXX_DiscardUnknown Uses

func (m *FinishTransactionRequest) XXX_DiscardUnknown()

func (*FinishTransactionRequest) XXX_Marshal Uses

func (m *FinishTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FinishTransactionRequest) XXX_Merge Uses

func (m *FinishTransactionRequest) XXX_Merge(src proto.Message)

func (*FinishTransactionRequest) XXX_Size Uses

func (m *FinishTransactionRequest) XXX_Size() int

func (*FinishTransactionRequest) XXX_Unmarshal Uses

func (m *FinishTransactionRequest) XXX_Unmarshal(b []byte) error

type InspectTransactionRequest Uses

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 Uses

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

func (*InspectTransactionRequest) GetTransaction Uses

func (m *InspectTransactionRequest) GetTransaction() *Transaction

func (*InspectTransactionRequest) Marshal Uses

func (m *InspectTransactionRequest) Marshal() (dAtA []byte, err error)

func (*InspectTransactionRequest) MarshalTo Uses

func (m *InspectTransactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*InspectTransactionRequest) MarshalToSizedBuffer Uses

func (m *InspectTransactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectTransactionRequest) ProtoMessage Uses

func (*InspectTransactionRequest) ProtoMessage()

func (*InspectTransactionRequest) Reset Uses

func (m *InspectTransactionRequest) Reset()

func (*InspectTransactionRequest) Size Uses

func (m *InspectTransactionRequest) Size() (n int)

func (*InspectTransactionRequest) String Uses

func (m *InspectTransactionRequest) String() string

func (*InspectTransactionRequest) Unmarshal Uses

func (m *InspectTransactionRequest) Unmarshal(dAtA []byte) error

func (*InspectTransactionRequest) XXX_DiscardUnknown Uses

func (m *InspectTransactionRequest) XXX_DiscardUnknown()

func (*InspectTransactionRequest) XXX_Marshal Uses

func (m *InspectTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectTransactionRequest) XXX_Merge Uses

func (m *InspectTransactionRequest) XXX_Merge(src proto.Message)

func (*InspectTransactionRequest) XXX_Size Uses

func (m *InspectTransactionRequest) XXX_Size() int

func (*InspectTransactionRequest) XXX_Unmarshal Uses

func (m *InspectTransactionRequest) XXX_Unmarshal(b []byte) error

type ListTransactionRequest Uses

type ListTransactionRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListTransactionRequest) Descriptor Uses

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

func (*ListTransactionRequest) Marshal Uses

func (m *ListTransactionRequest) Marshal() (dAtA []byte, err error)

func (*ListTransactionRequest) MarshalTo Uses

func (m *ListTransactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListTransactionRequest) MarshalToSizedBuffer Uses

func (m *ListTransactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListTransactionRequest) ProtoMessage Uses

func (*ListTransactionRequest) ProtoMessage()

func (*ListTransactionRequest) Reset Uses

func (m *ListTransactionRequest) Reset()

func (*ListTransactionRequest) Size Uses

func (m *ListTransactionRequest) Size() (n int)

func (*ListTransactionRequest) String Uses

func (m *ListTransactionRequest) String() string

func (*ListTransactionRequest) Unmarshal Uses

func (m *ListTransactionRequest) Unmarshal(dAtA []byte) error

func (*ListTransactionRequest) XXX_DiscardUnknown Uses

func (m *ListTransactionRequest) XXX_DiscardUnknown()

func (*ListTransactionRequest) XXX_Marshal Uses

func (m *ListTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTransactionRequest) XXX_Merge Uses

func (m *ListTransactionRequest) XXX_Merge(src proto.Message)

func (*ListTransactionRequest) XXX_Size Uses

func (m *ListTransactionRequest) XXX_Size() int

func (*ListTransactionRequest) XXX_Unmarshal Uses

func (m *ListTransactionRequest) XXX_Unmarshal(b []byte) error

type StartTransactionRequest Uses

type StartTransactionRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*StartTransactionRequest) Descriptor Uses

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

func (*StartTransactionRequest) Marshal Uses

func (m *StartTransactionRequest) Marshal() (dAtA []byte, err error)

func (*StartTransactionRequest) MarshalTo Uses

func (m *StartTransactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartTransactionRequest) MarshalToSizedBuffer Uses

func (m *StartTransactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartTransactionRequest) ProtoMessage Uses

func (*StartTransactionRequest) ProtoMessage()

func (*StartTransactionRequest) Reset Uses

func (m *StartTransactionRequest) Reset()

func (*StartTransactionRequest) Size Uses

func (m *StartTransactionRequest) Size() (n int)

func (*StartTransactionRequest) String Uses

func (m *StartTransactionRequest) String() string

func (*StartTransactionRequest) Unmarshal Uses

func (m *StartTransactionRequest) Unmarshal(dAtA []byte) error

func (*StartTransactionRequest) XXX_DiscardUnknown Uses

func (m *StartTransactionRequest) XXX_DiscardUnknown()

func (*StartTransactionRequest) XXX_Marshal Uses

func (m *StartTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTransactionRequest) XXX_Merge Uses

func (m *StartTransactionRequest) XXX_Merge(src proto.Message)

func (*StartTransactionRequest) XXX_Size Uses

func (m *StartTransactionRequest) XXX_Size() int

func (*StartTransactionRequest) XXX_Unmarshal Uses

func (m *StartTransactionRequest) XXX_Unmarshal(b []byte) error

type Transaction Uses

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 Uses

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

func (*Transaction) GetID Uses

func (m *Transaction) GetID() string

func (*Transaction) Marshal Uses

func (m *Transaction) Marshal() (dAtA []byte, err error)

func (*Transaction) MarshalTo Uses

func (m *Transaction) MarshalTo(dAtA []byte) (int, error)

func (*Transaction) MarshalToSizedBuffer Uses

func (m *Transaction) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Transaction) ProtoMessage Uses

func (*Transaction) ProtoMessage()

func (*Transaction) Reset Uses

func (m *Transaction) Reset()

func (*Transaction) Size Uses

func (m *Transaction) Size() (n int)

func (*Transaction) String Uses

func (m *Transaction) String() string

func (*Transaction) Unmarshal Uses

func (m *Transaction) Unmarshal(dAtA []byte) error

func (*Transaction) XXX_DiscardUnknown Uses

func (m *Transaction) XXX_DiscardUnknown()

func (*Transaction) XXX_Marshal Uses

func (m *Transaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Transaction) XXX_Merge Uses

func (m *Transaction) XXX_Merge(src proto.Message)

func (*Transaction) XXX_Size Uses

func (m *Transaction) XXX_Size() int

func (*Transaction) XXX_Unmarshal Uses

func (m *Transaction) XXX_Unmarshal(b []byte) error

type TransactionInfo Uses

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 Uses

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

func (*TransactionInfo) GetRequests Uses

func (m *TransactionInfo) GetRequests() []*TransactionRequest

func (*TransactionInfo) GetResponses Uses

func (m *TransactionInfo) GetResponses() []*TransactionResponse

func (*TransactionInfo) GetStarted Uses

func (m *TransactionInfo) GetStarted() *types.Timestamp

func (*TransactionInfo) GetTransaction Uses

func (m *TransactionInfo) GetTransaction() *Transaction

func (*TransactionInfo) Marshal Uses

func (m *TransactionInfo) Marshal() (dAtA []byte, err error)

func (*TransactionInfo) MarshalTo Uses

func (m *TransactionInfo) MarshalTo(dAtA []byte) (int, error)

func (*TransactionInfo) MarshalToSizedBuffer Uses

func (m *TransactionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionInfo) ProtoMessage Uses

func (*TransactionInfo) ProtoMessage()

func (*TransactionInfo) Reset Uses

func (m *TransactionInfo) Reset()

func (*TransactionInfo) Size Uses

func (m *TransactionInfo) Size() (n int)

func (*TransactionInfo) String Uses

func (m *TransactionInfo) String() string

func (*TransactionInfo) Unmarshal Uses

func (m *TransactionInfo) Unmarshal(dAtA []byte) error

func (*TransactionInfo) XXX_DiscardUnknown Uses

func (m *TransactionInfo) XXX_DiscardUnknown()

func (*TransactionInfo) XXX_Marshal Uses

func (m *TransactionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionInfo) XXX_Merge Uses

func (m *TransactionInfo) XXX_Merge(src proto.Message)

func (*TransactionInfo) XXX_Size Uses

func (m *TransactionInfo) XXX_Size() int

func (*TransactionInfo) XXX_Unmarshal Uses

func (m *TransactionInfo) XXX_Unmarshal(b []byte) error

type TransactionInfos Uses

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 Uses

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

func (*TransactionInfos) GetTransactionInfo Uses

func (m *TransactionInfos) GetTransactionInfo() []*TransactionInfo

func (*TransactionInfos) Marshal Uses

func (m *TransactionInfos) Marshal() (dAtA []byte, err error)

func (*TransactionInfos) MarshalTo Uses

func (m *TransactionInfos) MarshalTo(dAtA []byte) (int, error)

func (*TransactionInfos) MarshalToSizedBuffer Uses

func (m *TransactionInfos) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionInfos) ProtoMessage Uses

func (*TransactionInfos) ProtoMessage()

func (*TransactionInfos) Reset Uses

func (m *TransactionInfos) Reset()

func (*TransactionInfos) Size Uses

func (m *TransactionInfos) Size() (n int)

func (*TransactionInfos) String Uses

func (m *TransactionInfos) String() string

func (*TransactionInfos) Unmarshal Uses

func (m *TransactionInfos) Unmarshal(dAtA []byte) error

func (*TransactionInfos) XXX_DiscardUnknown Uses

func (m *TransactionInfos) XXX_DiscardUnknown()

func (*TransactionInfos) XXX_Marshal Uses

func (m *TransactionInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionInfos) XXX_Merge Uses

func (m *TransactionInfos) XXX_Merge(src proto.Message)

func (*TransactionInfos) XXX_Size Uses

func (m *TransactionInfos) XXX_Size() int

func (*TransactionInfos) XXX_Unmarshal Uses

func (m *TransactionInfos) XXX_Unmarshal(b []byte) error

type TransactionRequest Uses

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 Uses

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

func (*TransactionRequest) GetCreateBranch Uses

func (m *TransactionRequest) GetCreateBranch() *pfs.CreateBranchRequest

func (*TransactionRequest) GetCreateRepo Uses

func (m *TransactionRequest) GetCreateRepo() *pfs.CreateRepoRequest

func (*TransactionRequest) GetDeleteAll Uses

func (m *TransactionRequest) GetDeleteAll() *DeleteAllRequest

func (*TransactionRequest) GetDeleteBranch Uses

func (m *TransactionRequest) GetDeleteBranch() *pfs.DeleteBranchRequest

func (*TransactionRequest) GetDeleteCommit Uses

func (m *TransactionRequest) GetDeleteCommit() *pfs.DeleteCommitRequest

func (*TransactionRequest) GetDeleteRepo Uses

func (m *TransactionRequest) GetDeleteRepo() *pfs.DeleteRepoRequest

func (*TransactionRequest) GetFinishCommit Uses

func (m *TransactionRequest) GetFinishCommit() *pfs.FinishCommitRequest

func (*TransactionRequest) GetStartCommit Uses

func (m *TransactionRequest) GetStartCommit() *pfs.StartCommitRequest

func (*TransactionRequest) Marshal Uses

func (m *TransactionRequest) Marshal() (dAtA []byte, err error)

func (*TransactionRequest) MarshalTo Uses

func (m *TransactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*TransactionRequest) MarshalToSizedBuffer Uses

func (m *TransactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionRequest) ProtoMessage Uses

func (*TransactionRequest) ProtoMessage()

func (*TransactionRequest) Reset Uses

func (m *TransactionRequest) Reset()

func (*TransactionRequest) Size Uses

func (m *TransactionRequest) Size() (n int)

func (*TransactionRequest) String Uses

func (m *TransactionRequest) String() string

func (*TransactionRequest) Unmarshal Uses

func (m *TransactionRequest) Unmarshal(dAtA []byte) error

func (*TransactionRequest) XXX_DiscardUnknown Uses

func (m *TransactionRequest) XXX_DiscardUnknown()

func (*TransactionRequest) XXX_Marshal Uses

func (m *TransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionRequest) XXX_Merge Uses

func (m *TransactionRequest) XXX_Merge(src proto.Message)

func (*TransactionRequest) XXX_Size Uses

func (m *TransactionRequest) XXX_Size() int

func (*TransactionRequest) XXX_Unmarshal Uses

func (m *TransactionRequest) XXX_Unmarshal(b []byte) error

type TransactionResponse Uses

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 Uses

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

func (*TransactionResponse) GetCommit Uses

func (m *TransactionResponse) GetCommit() *pfs.Commit

func (*TransactionResponse) Marshal Uses

func (m *TransactionResponse) Marshal() (dAtA []byte, err error)

func (*TransactionResponse) MarshalTo Uses

func (m *TransactionResponse) MarshalTo(dAtA []byte) (int, error)

func (*TransactionResponse) MarshalToSizedBuffer Uses

func (m *TransactionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionResponse) ProtoMessage Uses

func (*TransactionResponse) ProtoMessage()

func (*TransactionResponse) Reset Uses

func (m *TransactionResponse) Reset()

func (*TransactionResponse) Size Uses

func (m *TransactionResponse) Size() (n int)

func (*TransactionResponse) String Uses

func (m *TransactionResponse) String() string

func (*TransactionResponse) Unmarshal Uses

func (m *TransactionResponse) Unmarshal(dAtA []byte) error

func (*TransactionResponse) XXX_DiscardUnknown Uses

func (m *TransactionResponse) XXX_DiscardUnknown()

func (*TransactionResponse) XXX_Marshal Uses

func (m *TransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionResponse) XXX_Merge Uses

func (m *TransactionResponse) XXX_Merge(src proto.Message)

func (*TransactionResponse) XXX_Size Uses

func (m *TransactionResponse) XXX_Size() int

func (*TransactionResponse) XXX_Unmarshal Uses

func (m *TransactionResponse) XXX_Unmarshal(b []byte) error

type UnimplementedAPIServer Uses

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) DeleteAll Uses

func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *DeleteAllRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteTransaction Uses

func (*UnimplementedAPIServer) DeleteTransaction(ctx context.Context, req *DeleteTransactionRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) FinishTransaction Uses

func (*UnimplementedAPIServer) FinishTransaction(ctx context.Context, req *FinishTransactionRequest) (*TransactionInfo, error)

func (*UnimplementedAPIServer) InspectTransaction Uses

func (*UnimplementedAPIServer) InspectTransaction(ctx context.Context, req *InspectTransactionRequest) (*TransactionInfo, error)

func (*UnimplementedAPIServer) ListTransaction Uses

func (*UnimplementedAPIServer) ListTransaction(ctx context.Context, req *ListTransactionRequest) (*TransactionInfos, error)

func (*UnimplementedAPIServer) StartTransaction Uses

func (*UnimplementedAPIServer) StartTransaction(ctx context.Context, req *StartTransactionRequest) (*Transaction, error)

Package transaction imports 12 packages (graph) and is imported by 9 packages. Updated 2019-09-11. Refresh now. Tools for package owners.