api

package
v0.0.0-...-affef23 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2021 License: MIT Imports: 31 Imported by: 1

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	SubmitResponse_Status_name = map[int32]string{
		0: "OK",
	}
	SubmitResponse_Status_value = map[string]int32{
		"OK": 0,
	}
)

Enum value maps for SubmitResponse_Status.

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterTrustixLogAPIHandler 

func RegisterTrustixLogAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterTrustixLogAPIHandler registers the http handlers for service TrustixLogAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTrustixLogAPIHandlerClient 

func RegisterTrustixLogAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TrustixLogAPIClient) error

RegisterTrustixLogAPIHandlerClient registers the http handlers for service TrustixLogAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TrustixLogAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TrustixLogAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TrustixLogAPIClient" to call the correct interceptors.

func RegisterTrustixLogAPIHandlerFromEndpoint 

func RegisterTrustixLogAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTrustixLogAPIHandlerFromEndpoint is same as RegisterTrustixLogAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTrustixLogAPIHandlerServer 

func RegisterTrustixLogAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TrustixLogAPIServer) error

RegisterTrustixLogAPIHandlerServer registers the http handlers for service TrustixLogAPI to "mux". UnaryRPC :call TrustixLogAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterTrustixLogAPIHandlerFromEndpoint instead.

func RegisterTrustixLogAPIServer 

func RegisterTrustixLogAPIServer(s grpc.ServiceRegistrar, srv TrustixLogAPIServer)

Types

type FlushRequest 

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

func (*FlushRequest) Descriptor deprecated 

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

Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.

func (*FlushRequest) ProtoMessage 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) ProtoReflect 

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

func (*FlushRequest) Reset 

func (x *FlushRequest) Reset()

func (*FlushRequest) String 

func (x *FlushRequest) String() string

type FlushResponse 

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

func (*FlushResponse) Descriptor deprecated 

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

Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) ProtoReflect 

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

func (*FlushResponse) Reset 

func (x *FlushResponse) Reset()

func (*FlushResponse) String 

func (x *FlushResponse) String() string

type GetLogAuditProofRequest 

type GetLogAuditProofRequest struct {
	Index    *uint64 `protobuf:"varint,1,req,name=Index" json:"Index,omitempty"`
	TreeSize *uint64 `protobuf:"varint,2,req,name=TreeSize" json:"TreeSize,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogAuditProofRequest) Descriptor deprecated 

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

Deprecated: Use GetLogAuditProofRequest.ProtoReflect.Descriptor instead.

func (*GetLogAuditProofRequest) GetIndex 

func (x *GetLogAuditProofRequest) GetIndex() uint64

func (*GetLogAuditProofRequest) GetTreeSize 

func (x *GetLogAuditProofRequest) GetTreeSize() uint64

func (*GetLogAuditProofRequest) ProtoMessage 

func (*GetLogAuditProofRequest) ProtoMessage()

func (*GetLogAuditProofRequest) ProtoReflect 

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

func (*GetLogAuditProofRequest) Reset 

func (x *GetLogAuditProofRequest) Reset()

func (*GetLogAuditProofRequest) String 

func (x *GetLogAuditProofRequest) String() string

type GetLogConsistencyProofRequest 

type GetLogConsistencyProofRequest struct {
	FirstSize  *uint64 `protobuf:"varint,1,req,name=FirstSize" json:"FirstSize,omitempty"`
	SecondSize *uint64 `protobuf:"varint,2,req,name=SecondSize" json:"SecondSize,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogConsistencyProofRequest) Descriptor deprecated 

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

Deprecated: Use GetLogConsistencyProofRequest.ProtoReflect.Descriptor instead.

func (*GetLogConsistencyProofRequest) GetFirstSize 

func (x *GetLogConsistencyProofRequest) GetFirstSize() uint64

func (*GetLogConsistencyProofRequest) GetSecondSize 

func (x *GetLogConsistencyProofRequest) GetSecondSize() uint64

func (*GetLogConsistencyProofRequest) ProtoMessage 

func (*GetLogConsistencyProofRequest) ProtoMessage()

func (*GetLogConsistencyProofRequest) ProtoReflect 

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

func (*GetLogConsistencyProofRequest) Reset 

func (x *GetLogConsistencyProofRequest) Reset()

func (*GetLogConsistencyProofRequest) String 

func (x *GetLogConsistencyProofRequest) String() string

type GetLogEntriesRequest 

type GetLogEntriesRequest struct {
	Start  *uint64 `protobuf:"varint,1,req,name=Start" json:"Start,omitempty"`
	Finish *uint64 `protobuf:"varint,2,req,name=Finish" json:"Finish,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogEntriesRequest) Descriptor deprecated 

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

Deprecated: Use GetLogEntriesRequest.ProtoReflect.Descriptor instead.

func (*GetLogEntriesRequest) GetFinish 

func (x *GetLogEntriesRequest) GetFinish() uint64

func (*GetLogEntriesRequest) GetStart 

func (x *GetLogEntriesRequest) GetStart() uint64

func (*GetLogEntriesRequest) ProtoMessage 

func (*GetLogEntriesRequest) ProtoMessage()

func (*GetLogEntriesRequest) ProtoReflect 

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

func (*GetLogEntriesRequest) Reset 

func (x *GetLogEntriesRequest) Reset()

func (*GetLogEntriesRequest) String 

func (x *GetLogEntriesRequest) String() string

type GetMapValueRequest 

type GetMapValueRequest struct {
	Key     []byte `protobuf:"bytes,1,req,name=Key" json:"Key,omitempty"`
	MapRoot []byte `protobuf:"bytes,2,req,name=MapRoot" json:"MapRoot,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMapValueRequest) Descriptor deprecated 

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

Deprecated: Use GetMapValueRequest.ProtoReflect.Descriptor instead.

func (*GetMapValueRequest) GetKey 

func (x *GetMapValueRequest) GetKey() []byte

func (*GetMapValueRequest) GetMapRoot 

func (x *GetMapValueRequest) GetMapRoot() []byte

func (*GetMapValueRequest) ProtoMessage 

func (*GetMapValueRequest) ProtoMessage()

func (*GetMapValueRequest) ProtoReflect 

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

func (*GetMapValueRequest) Reset 

func (x *GetMapValueRequest) Reset()

func (*GetMapValueRequest) String 

func (x *GetMapValueRequest) String() string

type KeyValuePair 

type KeyValuePair struct {
	Key   []byte `protobuf:"bytes,1,req,name=Key" json:"Key,omitempty"`
	Value []byte `protobuf:"bytes,2,req,name=Value" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValuePair) Descriptor deprecated 

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

Deprecated: Use KeyValuePair.ProtoReflect.Descriptor instead.

func (*KeyValuePair) GetKey 

func (x *KeyValuePair) GetKey() []byte

func (*KeyValuePair) GetValue 

func (x *KeyValuePair) GetValue() []byte

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) ProtoReflect 

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

func (*KeyValuePair) Reset 

func (x *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (x *KeyValuePair) String() string

type LogEntriesResponse 

type LogEntriesResponse struct {
	Leaves []*schema.LogLeaf `protobuf:"bytes,1,rep,name=Leaves" json:"Leaves,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntriesResponse) Descriptor deprecated 

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

Deprecated: Use LogEntriesResponse.ProtoReflect.Descriptor instead.

func (*LogEntriesResponse) GetLeaves 

func (x *LogEntriesResponse) GetLeaves() []*schema.LogLeaf

func (*LogEntriesResponse) ProtoMessage 

func (*LogEntriesResponse) ProtoMessage()

func (*LogEntriesResponse) ProtoReflect 

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

func (*LogEntriesResponse) Reset 

func (x *LogEntriesResponse) Reset()

func (*LogEntriesResponse) String 

func (x *LogEntriesResponse) String() string

type MapValueResponse 

type MapValueResponse struct {

	// Note that the Value field is actually a MapEntry
	// but we need to return the marshaled version
	// as that's what the proof is created from
	Value []byte                    `protobuf:"bytes,1,req,name=Value" json:"Value,omitempty"`
	Proof *SparseCompactMerkleProof `protobuf:"bytes,2,req,name=Proof" json:"Proof,omitempty"`
	// contains filtered or unexported fields
}

func (*MapValueResponse) Descriptor deprecated 

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

Deprecated: Use MapValueResponse.ProtoReflect.Descriptor instead.

func (*MapValueResponse) GetProof 

func (x *MapValueResponse) GetProof() *SparseCompactMerkleProof

func (*MapValueResponse) GetValue 

func (x *MapValueResponse) GetValue() []byte

func (*MapValueResponse) ProtoMessage 

func (*MapValueResponse) ProtoMessage()

func (*MapValueResponse) ProtoReflect 

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

func (*MapValueResponse) Reset 

func (x *MapValueResponse) Reset()

func (*MapValueResponse) String 

func (x *MapValueResponse) String() string

type ProofResponse 

type ProofResponse struct {
	Proof [][]byte `protobuf:"bytes,1,rep,name=Proof" json:"Proof,omitempty"`
	// contains filtered or unexported fields
}

func (*ProofResponse) Descriptor deprecated 

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

Deprecated: Use ProofResponse.ProtoReflect.Descriptor instead.

func (*ProofResponse) GetProof 

func (x *ProofResponse) GetProof() [][]byte

func (*ProofResponse) ProtoMessage 

func (*ProofResponse) ProtoMessage()

func (*ProofResponse) ProtoReflect 

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

func (*ProofResponse) Reset 

func (x *ProofResponse) Reset()

func (*ProofResponse) String 

func (x *ProofResponse) String() string

type STHRequest 

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

func (*STHRequest) Descriptor deprecated 

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

Deprecated: Use STHRequest.ProtoReflect.Descriptor instead.

func (*STHRequest) ProtoMessage 

func (*STHRequest) ProtoMessage()

func (*STHRequest) ProtoReflect 

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

func (*STHRequest) Reset 

func (x *STHRequest) Reset()

func (*STHRequest) String 

func (x *STHRequest) String() string

type SparseCompactMerkleProof 

type SparseCompactMerkleProof struct {
	SideNodes             [][]byte `protobuf:"bytes,1,rep,name=SideNodes" json:"SideNodes,omitempty"`
	NonMembershipLeafData []byte   `protobuf:"bytes,2,req,name=NonMembershipLeafData" json:"NonMembershipLeafData,omitempty"`
	BitMask               []byte   `protobuf:"bytes,3,req,name=BitMask" json:"BitMask,omitempty"`
	NumSideNodes          *uint64  `protobuf:"varint,4,req,name=NumSideNodes" json:"NumSideNodes,omitempty"`
	// contains filtered or unexported fields
}

func (*SparseCompactMerkleProof) Descriptor deprecated 

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

Deprecated: Use SparseCompactMerkleProof.ProtoReflect.Descriptor instead.

func (*SparseCompactMerkleProof) GetBitMask 

func (x *SparseCompactMerkleProof) GetBitMask() []byte

func (*SparseCompactMerkleProof) GetNonMembershipLeafData 

func (x *SparseCompactMerkleProof) GetNonMembershipLeafData() []byte

func (*SparseCompactMerkleProof) GetNumSideNodes 

func (x *SparseCompactMerkleProof) GetNumSideNodes() uint64

func (*SparseCompactMerkleProof) GetSideNodes 

func (x *SparseCompactMerkleProof) GetSideNodes() [][]byte

func (*SparseCompactMerkleProof) ProtoMessage 

func (*SparseCompactMerkleProof) ProtoMessage()

func (*SparseCompactMerkleProof) ProtoReflect 

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

func (*SparseCompactMerkleProof) Reset 

func (x *SparseCompactMerkleProof) Reset()

func (*SparseCompactMerkleProof) String 

func (x *SparseCompactMerkleProof) String() string

type SubmitRequest 

type SubmitRequest struct {
	Items []*KeyValuePair `protobuf:"bytes,1,rep,name=Items" json:"Items,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitRequest) Descriptor deprecated 

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

Deprecated: Use SubmitRequest.ProtoReflect.Descriptor instead.

func (*SubmitRequest) GetItems 

func (x *SubmitRequest) GetItems() []*KeyValuePair

func (*SubmitRequest) ProtoMessage 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) ProtoReflect 

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

func (*SubmitRequest) Reset 

func (x *SubmitRequest) Reset()

func (*SubmitRequest) String 

func (x *SubmitRequest) String() string

type SubmitResponse 

type SubmitResponse struct {
	Status *SubmitResponse_Status `protobuf:"varint,1,req,name=status,enum=trustix.SubmitResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitResponse) Descriptor deprecated 

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

Deprecated: Use SubmitResponse.ProtoReflect.Descriptor instead.

func (*SubmitResponse) GetStatus 

func (x *SubmitResponse) GetStatus() SubmitResponse_Status

func (*SubmitResponse) ProtoMessage 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) ProtoReflect 

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

func (*SubmitResponse) Reset 

func (x *SubmitResponse) Reset()

func (*SubmitResponse) String 

func (x *SubmitResponse) String() string

type SubmitResponse_Status 

type SubmitResponse_Status int32
const (
	SubmitResponse_OK SubmitResponse_Status = 0
)

func (SubmitResponse_Status) Descriptor 

func (SubmitResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (SubmitResponse_Status) Enum 

func (x SubmitResponse_Status) Enum() *SubmitResponse_Status

func (SubmitResponse_Status) EnumDescriptor deprecated 

func (SubmitResponse_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use SubmitResponse_Status.Descriptor instead.

func (SubmitResponse_Status) Number 

func (x SubmitResponse_Status) Number() protoreflect.EnumNumber

func (SubmitResponse_Status) String 

func (x SubmitResponse_Status) String() string

func (SubmitResponse_Status) Type 

func (SubmitResponse_Status) Type() protoreflect.EnumType

func (*SubmitResponse_Status) UnmarshalJSON deprecated 

func (x *SubmitResponse_Status) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TrustixAPIGRPCClient 

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

TrustixAPIGRPCClient is a gRPC based implementation of TrustixLogAPI wrapping a gRPC ClientConn

func NewTrustixAPIGRPCClient 

func NewTrustixAPIGRPCClient(conn *grpc.ClientConn) (*TrustixAPIGRPCClient, error)

func (*TrustixAPIGRPCClient) Flush 

func (s *TrustixAPIGRPCClient) Flush(ctx context.Context, in *FlushRequest) (*FlushResponse, error)

func (*TrustixAPIGRPCClient) GetLogAuditProof 

func (s *TrustixAPIGRPCClient) GetLogAuditProof(ctx context.Context, req *GetLogAuditProofRequest) (*ProofResponse, error)

func (*TrustixAPIGRPCClient) GetLogConsistencyProof 

func (s *TrustixAPIGRPCClient) GetLogConsistencyProof(ctx context.Context, req *GetLogConsistencyProofRequest) (*ProofResponse, error)

func (*TrustixAPIGRPCClient) GetLogEntries 

func (s *TrustixAPIGRPCClient) GetLogEntries(ctx context.Context, req *GetLogEntriesRequest) (*LogEntriesResponse, error)

func (*TrustixAPIGRPCClient) GetMHLogAuditProof 

func (s *TrustixAPIGRPCClient) GetMHLogAuditProof(ctx context.Context, req *GetLogAuditProofRequest) (*ProofResponse, error)

func (*TrustixAPIGRPCClient) GetMHLogConsistencyProof 

func (s *TrustixAPIGRPCClient) GetMHLogConsistencyProof(ctx context.Context, req *GetLogConsistencyProofRequest) (*ProofResponse, error)

func (*TrustixAPIGRPCClient) GetMHLogEntries 

func (s *TrustixAPIGRPCClient) GetMHLogEntries(ctx context.Context, req *GetLogEntriesRequest) (*LogEntriesResponse, error)

func (*TrustixAPIGRPCClient) GetMapValue 

func (s *TrustixAPIGRPCClient) GetMapValue(ctx context.Context, req *GetMapValueRequest) (*MapValueResponse, error)

func (*TrustixAPIGRPCClient) GetSTH 

func (s *TrustixAPIGRPCClient) GetSTH(ctx context.Context, req *STHRequest) (*schema.STH, error)

func (*TrustixAPIGRPCClient) GetValue 

func (s *TrustixAPIGRPCClient) GetValue(ctx context.Context, in *ValueRequest) (*ValueResponse, error)

func (*TrustixAPIGRPCClient) Submit 

func (s *TrustixAPIGRPCClient) Submit(ctx context.Context, req *SubmitRequest) (*SubmitResponse, error)

type TrustixAPIServer 

type TrustixAPIServer struct {
	UnimplementedTrustixLogAPIServer
	// contains filtered or unexported fields
}

TrustixAPIServer wraps kvStoreLogApi and turns it into a gRPC implementation

func NewTrustixAPIServer 

func NewTrustixAPIServer(impl TrustixLogAPI) (*TrustixAPIServer, error)

func (*TrustixAPIServer) Flush 

func (s *TrustixAPIServer) Flush(ctx context.Context, req *FlushRequest) (*FlushResponse, error)

func (*TrustixAPIServer) GetLogAuditProof 

func (s *TrustixAPIServer) GetLogAuditProof(ctx context.Context, req *GetLogAuditProofRequest) (*ProofResponse, error)

func (*TrustixAPIServer) GetLogConsistencyProof 

func (s *TrustixAPIServer) GetLogConsistencyProof(ctx context.Context, req *GetLogConsistencyProofRequest) (*ProofResponse, error)

func (*TrustixAPIServer) GetLogEntries 

func (s *TrustixAPIServer) GetLogEntries(ctx context.Context, req *GetLogEntriesRequest) (*LogEntriesResponse, error)

func (*TrustixAPIServer) GetMHLogAuditProof 

func (s *TrustixAPIServer) GetMHLogAuditProof(ctx context.Context, req *GetLogAuditProofRequest) (*ProofResponse, error)

func (*TrustixAPIServer) GetMHLogConsistencyProof 

func (s *TrustixAPIServer) GetMHLogConsistencyProof(ctx context.Context, req *GetLogConsistencyProofRequest) (*ProofResponse, error)

func (*TrustixAPIServer) GetMHLogEntries 

func (s *TrustixAPIServer) GetMHLogEntries(ctx context.Context, req *GetLogEntriesRequest) (*LogEntriesResponse, error)

func (*TrustixAPIServer) GetMapValue 

func (s *TrustixAPIServer) GetMapValue(ctx context.Context, req *GetMapValueRequest) (*MapValueResponse, error)

func (*TrustixAPIServer) GetSTH 

func (s *TrustixAPIServer) GetSTH(ctx context.Context, req *STHRequest) (*schema.STH, error)

func (*TrustixAPIServer) GetValue 

func (s *TrustixAPIServer) GetValue(ctx context.Context, req *ValueRequest) (*ValueResponse, error)

func (*TrustixAPIServer) Submit 

func (s *TrustixAPIServer) Submit(ctx context.Context, req *SubmitRequest) (*SubmitResponse, error)

type TrustixLogAPI 

type TrustixLogAPI interface {
	// GetSTH - Get a signed tree head
	GetSTH(context.Context, *STHRequest) (*schema.STH, error)

	// Get log consistency proof
	GetLogConsistencyProof(context.Context, *GetLogConsistencyProofRequest) (*ProofResponse, error)

	// Get leaf audit proof
	GetLogAuditProof(context.Context, *GetLogAuditProofRequest) (*ProofResponse, error)

	// Get log entries (batched)
	GetLogEntries(context.Context, *GetLogEntriesRequest) (*LogEntriesResponse, error)

	// Get value from the map
	GetMapValue(context.Context, *GetMapValueRequest) (*MapValueResponse, error)

	// Submit a value to the log
	Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)

	// Flush the queue and write new heads
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)

	// Get content-addressed computation outputs
	GetValue(context.Context, *ValueRequest) (*ValueResponse, error)

	// Get map head log consistency proof
	GetMHLogConsistencyProof(context.Context, *GetLogConsistencyProofRequest) (*ProofResponse, error)

	// Get map head log leaf audit proof
	GetMHLogAuditProof(context.Context, *GetLogAuditProofRequest) (*ProofResponse, error)

	// Get map head log entries (batched)
	GetMHLogEntries(context.Context, *GetLogEntriesRequest) (*LogEntriesResponse, error)
}

func NewKVStoreAPI 

func NewKVStoreAPI(store storage.TrustixStorage, signer crypto.Signer) (TrustixLogAPI, error)

NewKVStoreAPI - Returns an instance of the log API for an authoritive log implemented on top of a key/value store

This is the underlying implementation used by all other abstractions

type TrustixLogAPIClient 

type TrustixLogAPIClient interface {
	GetSTH(ctx context.Context, in *STHRequest, opts ...grpc.CallOption) (*schema.STH, error)
	Submit(ctx context.Context, in *SubmitRequest, opts ...grpc.CallOption) (*SubmitResponse, error)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	GetValue(ctx context.Context, in *ValueRequest, opts ...grpc.CallOption) (*ValueResponse, error)
	GetLogConsistencyProof(ctx context.Context, in *GetLogConsistencyProofRequest, opts ...grpc.CallOption) (*ProofResponse, error)
	GetLogAuditProof(ctx context.Context, in *GetLogAuditProofRequest, opts ...grpc.CallOption) (*ProofResponse, error)
	GetLogEntries(ctx context.Context, in *GetLogEntriesRequest, opts ...grpc.CallOption) (*LogEntriesResponse, error)
	GetMapValue(ctx context.Context, in *GetMapValueRequest, opts ...grpc.CallOption) (*MapValueResponse, error)
	GetMHLogConsistencyProof(ctx context.Context, in *GetLogConsistencyProofRequest, opts ...grpc.CallOption) (*ProofResponse, error)
	GetMHLogAuditProof(ctx context.Context, in *GetLogAuditProofRequest, opts ...grpc.CallOption) (*ProofResponse, error)
	GetMHLogEntries(ctx context.Context, in *GetLogEntriesRequest, opts ...grpc.CallOption) (*LogEntriesResponse, error)
}

TrustixLogAPIClient is the client API for TrustixLogAPI 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 NewTrustixLogAPIClient 

func NewTrustixLogAPIClient(cc grpc.ClientConnInterface) TrustixLogAPIClient

type TrustixLogAPIServer 

type TrustixLogAPIServer interface {
	GetSTH(context.Context, *STHRequest) (*schema.STH, error)
	Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	GetValue(context.Context, *ValueRequest) (*ValueResponse, error)
	GetLogConsistencyProof(context.Context, *GetLogConsistencyProofRequest) (*ProofResponse, error)
	GetLogAuditProof(context.Context, *GetLogAuditProofRequest) (*ProofResponse, error)
	GetLogEntries(context.Context, *GetLogEntriesRequest) (*LogEntriesResponse, error)
	GetMapValue(context.Context, *GetMapValueRequest) (*MapValueResponse, error)
	GetMHLogConsistencyProof(context.Context, *GetLogConsistencyProofRequest) (*ProofResponse, error)
	GetMHLogAuditProof(context.Context, *GetLogAuditProofRequest) (*ProofResponse, error)
	GetMHLogEntries(context.Context, *GetLogEntriesRequest) (*LogEntriesResponse, error)
	// contains filtered or unexported methods
}

TrustixLogAPIServer is the server API for TrustixLogAPI service. All implementations must embed UnimplementedTrustixLogAPIServer for forward compatibility

type UnimplementedTrustixLogAPIServer 

type UnimplementedTrustixLogAPIServer struct {
}

UnimplementedTrustixLogAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedTrustixLogAPIServer) Flush 

func (UnimplementedTrustixLogAPIServer) Flush(context.Context, *FlushRequest) (*FlushResponse, error)

func (UnimplementedTrustixLogAPIServer) GetLogAuditProof 

func (UnimplementedTrustixLogAPIServer) GetLogAuditProof(context.Context, *GetLogAuditProofRequest) (*ProofResponse, error)

func (UnimplementedTrustixLogAPIServer) GetLogConsistencyProof 

func (UnimplementedTrustixLogAPIServer) GetLogConsistencyProof(context.Context, *GetLogConsistencyProofRequest) (*ProofResponse, error)

func (UnimplementedTrustixLogAPIServer) GetLogEntries 

func (UnimplementedTrustixLogAPIServer) GetLogEntries(context.Context, *GetLogEntriesRequest) (*LogEntriesResponse, error)

func (UnimplementedTrustixLogAPIServer) GetMHLogAuditProof 

func (UnimplementedTrustixLogAPIServer) GetMHLogAuditProof(context.Context, *GetLogAuditProofRequest) (*ProofResponse, error)

func (UnimplementedTrustixLogAPIServer) GetMHLogConsistencyProof 

func (UnimplementedTrustixLogAPIServer) GetMHLogConsistencyProof(context.Context, *GetLogConsistencyProofRequest) (*ProofResponse, error)

func (UnimplementedTrustixLogAPIServer) GetMHLogEntries 

func (UnimplementedTrustixLogAPIServer) GetMHLogEntries(context.Context, *GetLogEntriesRequest) (*LogEntriesResponse, error)

func (UnimplementedTrustixLogAPIServer) GetMapValue 

func (UnimplementedTrustixLogAPIServer) GetMapValue(context.Context, *GetMapValueRequest) (*MapValueResponse, error)

func (UnimplementedTrustixLogAPIServer) GetSTH 

func (UnimplementedTrustixLogAPIServer) GetSTH(context.Context, *STHRequest) (*schema.STH, error)

func (UnimplementedTrustixLogAPIServer) GetValue 

func (UnimplementedTrustixLogAPIServer) GetValue(context.Context, *ValueRequest) (*ValueResponse, error)

func (UnimplementedTrustixLogAPIServer) Submit 

func (UnimplementedTrustixLogAPIServer) Submit(context.Context, *SubmitRequest) (*SubmitResponse, error)

type UnsafeTrustixLogAPIServer 

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

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

type ValueRequest 

type ValueRequest struct {
	Digest []byte `protobuf:"bytes,1,req,name=Digest" json:"Digest,omitempty"`
	// contains filtered or unexported fields
}

func (*ValueRequest) Descriptor deprecated 

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

Deprecated: Use ValueRequest.ProtoReflect.Descriptor instead.

func (*ValueRequest) GetDigest 

func (x *ValueRequest) GetDigest() []byte

func (*ValueRequest) ProtoMessage 

func (*ValueRequest) ProtoMessage()

func (*ValueRequest) ProtoReflect 

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

func (*ValueRequest) Reset 

func (x *ValueRequest) Reset()

func (*ValueRequest) String 

func (x *ValueRequest) String() string

type ValueResponse 

type ValueResponse struct {
	Value []byte `protobuf:"bytes,1,req,name=Value" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*ValueResponse) Descriptor deprecated 

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

Deprecated: Use ValueResponse.ProtoReflect.Descriptor instead.

func (*ValueResponse) GetValue 

func (x *ValueResponse) GetValue() []byte

func (*ValueResponse) ProtoMessage 

func (*ValueResponse) ProtoMessage()

func (*ValueResponse) ProtoReflect 

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

func (*ValueResponse) Reset 

func (x *ValueResponse) Reset()

func (*ValueResponse) String 

func (x *ValueResponse) 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.