consensusproto

package
v0.10.6 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2025 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrCodes_name = map[int32]string{
		0:   "Unexpected",
		1:   "LogExists",
		2:   "LogNotFound",
		3:   "RecordConflict",
		4:   "Forbidden",
		5:   "InvalidPayload",
		500: "ErrorOffset",
	}
	ErrCodes_value = map[string]int32{
		"Unexpected":     0,
		"LogExists":      1,
		"LogNotFound":    2,
		"RecordConflict": 3,
		"Forbidden":      4,
		"InvalidPayload": 5,
		"ErrorOffset":    500,
	}
)

Enum value maps for ErrCodes.

View Source 
var File_consensus_consensusproto_protos_consensus_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterConsensus 

func DRPCRegisterConsensus(mux drpc.Mux, impl DRPCConsensusServer) error

func GetHead added in v0.2.15 

func GetHead(msg *LogSyncMessage) (head string)

Types

type DRPCConsensusClient 

type DRPCConsensusClient interface {
	DRPCConn() drpc.Conn

	LogAdd(ctx context.Context, in *LogAddRequest) (*Ok, error)
	RecordAdd(ctx context.Context, in *RecordAddRequest) (*RawRecordWithId, error)
	LogWatch(ctx context.Context) (DRPCConsensus_LogWatchClient, error)
	LogDelete(ctx context.Context, in *LogDeleteRequest) (*Ok, error)
}

func NewDRPCConsensusClient 

func NewDRPCConsensusClient(cc drpc.Conn) DRPCConsensusClient

type DRPCConsensusDescription 

type DRPCConsensusDescription struct{}

func (DRPCConsensusDescription) Method 

func (DRPCConsensusDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCConsensusDescription) NumMethods 

func (DRPCConsensusDescription) NumMethods() int

type DRPCConsensusServer 

type DRPCConsensusServer interface {
	LogAdd(context.Context, *LogAddRequest) (*Ok, error)
	RecordAdd(context.Context, *RecordAddRequest) (*RawRecordWithId, error)
	LogWatch(DRPCConsensus_LogWatchStream) error
	LogDelete(context.Context, *LogDeleteRequest) (*Ok, error)
}

type DRPCConsensusUnimplementedServer 

type DRPCConsensusUnimplementedServer struct{}

func (*DRPCConsensusUnimplementedServer) LogAdd 

func (s *DRPCConsensusUnimplementedServer) LogAdd(context.Context, *LogAddRequest) (*Ok, error)

func (*DRPCConsensusUnimplementedServer) LogDelete added in v0.3.0 

func (s *DRPCConsensusUnimplementedServer) LogDelete(context.Context, *LogDeleteRequest) (*Ok, error)

func (*DRPCConsensusUnimplementedServer) LogWatch 

func (s *DRPCConsensusUnimplementedServer) LogWatch(DRPCConsensus_LogWatchStream) error

func (*DRPCConsensusUnimplementedServer) RecordAdd 

func (s *DRPCConsensusUnimplementedServer) RecordAdd(context.Context, *RecordAddRequest) (*RawRecordWithId, error)

type DRPCConsensus_LogAddStream 

type DRPCConsensus_LogAddStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCConsensus_LogDeleteStream added in v0.3.0 

type DRPCConsensus_LogDeleteStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCConsensus_LogWatchClient 

type DRPCConsensus_LogWatchClient interface {
	drpc.Stream
	Send(*LogWatchRequest) error
	Recv() (*LogWatchEvent, error)
}

type DRPCConsensus_LogWatchStream 

type DRPCConsensus_LogWatchStream interface {
	drpc.Stream
	Send(*LogWatchEvent) error
	Recv() (*LogWatchRequest, error)
}

type DRPCConsensus_RecordAddStream 

type DRPCConsensus_RecordAddStream interface {
	drpc.Stream
	SendAndClose(*RawRecordWithId) error
}

type Err 

type Err struct {
	Error ErrCodes `protobuf:"varint,1,opt,name=error,proto3,enum=consensusProto.ErrCodes" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Err) Descriptor deprecated 

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

Deprecated: Use Err.ProtoReflect.Descriptor instead.

func (*Err) GetError 

func (x *Err) GetError() ErrCodes

func (*Err) MarshalToSizedBufferVT added in v0.9.0 

func (m *Err) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Err) MarshalToVT added in v0.9.0 

func (m *Err) MarshalToVT(dAtA []byte) (int, error)

func (*Err) MarshalVT added in v0.9.0 

func (m *Err) MarshalVT() (dAtA []byte, err error)

func (*Err) ProtoMessage 

func (*Err) ProtoMessage()

func (*Err) ProtoReflect added in v0.9.0 

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

func (*Err) Reset 

func (x *Err) Reset()

func (*Err) SizeVT added in v0.9.0 

func (m *Err) SizeVT() (n int)

func (*Err) String 

func (x *Err) String() string

func (*Err) UnmarshalVT added in v0.9.0 

func (m *Err) UnmarshalVT(dAtA []byte) error

type ErrCodes 

type ErrCodes int32
const (
	ErrCodes_Unexpected     ErrCodes = 0
	ErrCodes_LogExists      ErrCodes = 1
	ErrCodes_LogNotFound    ErrCodes = 2
	ErrCodes_RecordConflict ErrCodes = 3
	ErrCodes_Forbidden      ErrCodes = 4
	ErrCodes_InvalidPayload ErrCodes = 5
	ErrCodes_ErrorOffset    ErrCodes = 500
)

func (ErrCodes) Descriptor added in v0.9.0 

func (ErrCodes) Descriptor() protoreflect.EnumDescriptor

func (ErrCodes) Enum added in v0.9.0 

func (x ErrCodes) Enum() *ErrCodes

func (ErrCodes) EnumDescriptor deprecated 

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

Deprecated: Use ErrCodes.Descriptor instead.

func (ErrCodes) Number added in v0.9.0 

func (x ErrCodes) Number() protoreflect.EnumNumber

func (ErrCodes) String 

func (x ErrCodes) String() string

func (ErrCodes) Type added in v0.9.0 

func (ErrCodes) Type() protoreflect.EnumType

type Log 

type Log struct {
	Id      string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Records []*RawRecordWithId `protobuf:"bytes,3,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetId 

func (x *Log) GetId() string

func (*Log) GetRecords 

func (x *Log) GetRecords() []*RawRecordWithId

func (*Log) MarshalToSizedBufferVT added in v0.9.0 

func (m *Log) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Log) MarshalToVT added in v0.9.0 

func (m *Log) MarshalToVT(dAtA []byte) (int, error)

func (*Log) MarshalVT added in v0.9.0 

func (m *Log) MarshalVT() (dAtA []byte, err error)

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect added in v0.9.0 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) SizeVT added in v0.9.0 

func (m *Log) SizeVT() (n int)

func (*Log) String 

func (x *Log) String() string

func (*Log) UnmarshalVT added in v0.9.0 

func (m *Log) UnmarshalVT(dAtA []byte) error

type LogAddRequest 

type LogAddRequest struct {
	LogId string `protobuf:"bytes,1,opt,name=logId,proto3" json:"logId,omitempty"`
	// first record in the log, consensus node not sign it
	Record *RawRecordWithId `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*LogAddRequest) Descriptor deprecated 

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

Deprecated: Use LogAddRequest.ProtoReflect.Descriptor instead.

func (*LogAddRequest) GetLogId added in v0.3.22 

func (x *LogAddRequest) GetLogId() string

func (*LogAddRequest) GetRecord added in v0.2.15 

func (x *LogAddRequest) GetRecord() *RawRecordWithId

func (*LogAddRequest) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogAddRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogAddRequest) MarshalToVT added in v0.9.0 

func (m *LogAddRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LogAddRequest) MarshalVT added in v0.9.0 

func (m *LogAddRequest) MarshalVT() (dAtA []byte, err error)

func (*LogAddRequest) ProtoMessage 

func (*LogAddRequest) ProtoMessage()

func (*LogAddRequest) ProtoReflect added in v0.9.0 

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

func (*LogAddRequest) Reset 

func (x *LogAddRequest) Reset()

func (*LogAddRequest) SizeVT added in v0.9.0 

func (m *LogAddRequest) SizeVT() (n int)

func (*LogAddRequest) String 

func (x *LogAddRequest) String() string

func (*LogAddRequest) UnmarshalVT added in v0.9.0 

func (m *LogAddRequest) UnmarshalVT(dAtA []byte) error

type LogDeleteRequest added in v0.3.0 

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

func (*LogDeleteRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use LogDeleteRequest.ProtoReflect.Descriptor instead.

func (*LogDeleteRequest) GetLogId added in v0.3.0 

func (x *LogDeleteRequest) GetLogId() string

func (*LogDeleteRequest) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogDeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogDeleteRequest) MarshalToVT added in v0.9.0 

func (m *LogDeleteRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LogDeleteRequest) MarshalVT added in v0.9.0 

func (m *LogDeleteRequest) MarshalVT() (dAtA []byte, err error)

func (*LogDeleteRequest) ProtoMessage added in v0.3.0 

func (*LogDeleteRequest) ProtoMessage()

func (*LogDeleteRequest) ProtoReflect added in v0.9.0 

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

func (*LogDeleteRequest) Reset added in v0.3.0 

func (x *LogDeleteRequest) Reset()

func (*LogDeleteRequest) SizeVT added in v0.9.0 

func (m *LogDeleteRequest) SizeVT() (n int)

func (*LogDeleteRequest) String added in v0.3.0 

func (x *LogDeleteRequest) String() string

func (*LogDeleteRequest) UnmarshalVT added in v0.9.0 

func (m *LogDeleteRequest) UnmarshalVT(dAtA []byte) error

type LogFullSyncRequest added in v0.2.15 

type LogFullSyncRequest struct {
	Head    string             `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Records []*RawRecordWithId `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

LogFullSyncRequest is a message sent when consensus log needs full sync

func (*LogFullSyncRequest) Descriptor deprecated added in v0.2.15 

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

Deprecated: Use LogFullSyncRequest.ProtoReflect.Descriptor instead.

func (*LogFullSyncRequest) GetHead added in v0.2.15 

func (x *LogFullSyncRequest) GetHead() string

func (*LogFullSyncRequest) GetRecords added in v0.2.15 

func (x *LogFullSyncRequest) GetRecords() []*RawRecordWithId

func (*LogFullSyncRequest) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogFullSyncRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogFullSyncRequest) MarshalToVT added in v0.9.0 

func (m *LogFullSyncRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LogFullSyncRequest) MarshalVT added in v0.9.0 

func (m *LogFullSyncRequest) MarshalVT() (dAtA []byte, err error)

func (*LogFullSyncRequest) ProtoMessage added in v0.2.15 

func (*LogFullSyncRequest) ProtoMessage()

func (*LogFullSyncRequest) ProtoReflect added in v0.9.0 

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

func (*LogFullSyncRequest) Reset added in v0.2.15 

func (x *LogFullSyncRequest) Reset()

func (*LogFullSyncRequest) SizeVT added in v0.9.0 

func (m *LogFullSyncRequest) SizeVT() (n int)

func (*LogFullSyncRequest) String added in v0.2.15 

func (x *LogFullSyncRequest) String() string

func (*LogFullSyncRequest) UnmarshalVT added in v0.9.0 

func (m *LogFullSyncRequest) UnmarshalVT(dAtA []byte) error

type LogFullSyncResponse added in v0.2.15 

type LogFullSyncResponse struct {
	Head    string             `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Records []*RawRecordWithId `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

LogFullSyncResponse is a message sent as a response for a specific full sync

func (*LogFullSyncResponse) Descriptor deprecated added in v0.2.15 

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

Deprecated: Use LogFullSyncResponse.ProtoReflect.Descriptor instead.

func (*LogFullSyncResponse) GetHead added in v0.2.15 

func (x *LogFullSyncResponse) GetHead() string

func (*LogFullSyncResponse) GetRecords added in v0.2.15 

func (x *LogFullSyncResponse) GetRecords() []*RawRecordWithId

func (*LogFullSyncResponse) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogFullSyncResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogFullSyncResponse) MarshalToVT added in v0.9.0 

func (m *LogFullSyncResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LogFullSyncResponse) MarshalVT added in v0.9.0 

func (m *LogFullSyncResponse) MarshalVT() (dAtA []byte, err error)

func (*LogFullSyncResponse) ProtoMessage added in v0.2.15 

func (*LogFullSyncResponse) ProtoMessage()

func (*LogFullSyncResponse) ProtoReflect added in v0.9.0 

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

func (*LogFullSyncResponse) Reset added in v0.2.15 

func (x *LogFullSyncResponse) Reset()

func (*LogFullSyncResponse) SizeVT added in v0.9.0 

func (m *LogFullSyncResponse) SizeVT() (n int)

func (*LogFullSyncResponse) String added in v0.2.15 

func (x *LogFullSyncResponse) String() string

func (*LogFullSyncResponse) UnmarshalVT added in v0.9.0 

func (m *LogFullSyncResponse) UnmarshalVT(dAtA []byte) error

type LogHeadUpdate added in v0.2.15 

type LogHeadUpdate struct {
	Head    string             `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Records []*RawRecordWithId `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

LogHeadUpdate is a message sent on consensus log head update

func (*LogHeadUpdate) Descriptor deprecated added in v0.2.15 

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

Deprecated: Use LogHeadUpdate.ProtoReflect.Descriptor instead.

func (*LogHeadUpdate) GetHead added in v0.2.15 

func (x *LogHeadUpdate) GetHead() string

func (*LogHeadUpdate) GetRecords added in v0.2.15 

func (x *LogHeadUpdate) GetRecords() []*RawRecordWithId

func (*LogHeadUpdate) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogHeadUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogHeadUpdate) MarshalToVT added in v0.9.0 

func (m *LogHeadUpdate) MarshalToVT(dAtA []byte) (int, error)

func (*LogHeadUpdate) MarshalVT added in v0.9.0 

func (m *LogHeadUpdate) MarshalVT() (dAtA []byte, err error)

func (*LogHeadUpdate) ProtoMessage added in v0.2.15 

func (*LogHeadUpdate) ProtoMessage()

func (*LogHeadUpdate) ProtoReflect added in v0.9.0 

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

func (*LogHeadUpdate) Reset added in v0.2.15 

func (x *LogHeadUpdate) Reset()

func (*LogHeadUpdate) SizeVT added in v0.9.0 

func (m *LogHeadUpdate) SizeVT() (n int)

func (*LogHeadUpdate) String added in v0.2.15 

func (x *LogHeadUpdate) String() string

func (*LogHeadUpdate) UnmarshalVT added in v0.9.0 

func (m *LogHeadUpdate) UnmarshalVT(dAtA []byte) error

type LogSyncContentValue added in v0.2.15 

type LogSyncContentValue struct {

	// Types that are valid to be assigned to Value:
	//
	//	*LogSyncContentValue_HeadUpdate
	//	*LogSyncContentValue_FullSyncRequest
	//	*LogSyncContentValue_FullSyncResponse
	Value isLogSyncContentValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

LogSyncContentValue provides different types for log sync

func (*LogSyncContentValue) Descriptor deprecated added in v0.2.15 

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

Deprecated: Use LogSyncContentValue.ProtoReflect.Descriptor instead.

func (*LogSyncContentValue) GetFullSyncRequest added in v0.2.15 

func (x *LogSyncContentValue) GetFullSyncRequest() *LogFullSyncRequest

func (*LogSyncContentValue) GetFullSyncResponse added in v0.2.15 

func (x *LogSyncContentValue) GetFullSyncResponse() *LogFullSyncResponse

func (*LogSyncContentValue) GetHeadUpdate added in v0.2.15 

func (x *LogSyncContentValue) GetHeadUpdate() *LogHeadUpdate

func (*LogSyncContentValue) GetValue added in v0.2.15 

func (x *LogSyncContentValue) GetValue() isLogSyncContentValue_Value

func (*LogSyncContentValue) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogSyncContentValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogSyncContentValue) MarshalToVT added in v0.9.0 

func (m *LogSyncContentValue) MarshalToVT(dAtA []byte) (int, error)

func (*LogSyncContentValue) MarshalVT added in v0.9.0 

func (m *LogSyncContentValue) MarshalVT() (dAtA []byte, err error)

func (*LogSyncContentValue) ProtoMessage added in v0.2.15 

func (*LogSyncContentValue) ProtoMessage()

func (*LogSyncContentValue) ProtoReflect added in v0.9.0 

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

func (*LogSyncContentValue) Reset added in v0.2.15 

func (x *LogSyncContentValue) Reset()

func (*LogSyncContentValue) SizeVT added in v0.9.0 

func (m *LogSyncContentValue) SizeVT() (n int)

func (*LogSyncContentValue) String added in v0.2.15 

func (x *LogSyncContentValue) String() string

func (*LogSyncContentValue) UnmarshalVT added in v0.9.0 

func (m *LogSyncContentValue) UnmarshalVT(dAtA []byte) error

type LogSyncContentValue_FullSyncRequest added in v0.2.15 

type LogSyncContentValue_FullSyncRequest struct {
	FullSyncRequest *LogFullSyncRequest `protobuf:"bytes,2,opt,name=fullSyncRequest,proto3,oneof"`
}

func (*LogSyncContentValue_FullSyncRequest) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogSyncContentValue_FullSyncRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogSyncContentValue_FullSyncRequest) MarshalToVT added in v0.9.0 

func (m *LogSyncContentValue_FullSyncRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LogSyncContentValue_FullSyncRequest) SizeVT added in v0.9.0 

func (m *LogSyncContentValue_FullSyncRequest) SizeVT() (n int)

type LogSyncContentValue_FullSyncResponse added in v0.2.15 

type LogSyncContentValue_FullSyncResponse struct {
	FullSyncResponse *LogFullSyncResponse `protobuf:"bytes,3,opt,name=fullSyncResponse,proto3,oneof"`
}

func (*LogSyncContentValue_FullSyncResponse) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogSyncContentValue_FullSyncResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogSyncContentValue_FullSyncResponse) MarshalToVT added in v0.9.0 

func (m *LogSyncContentValue_FullSyncResponse) MarshalToVT(dAtA []byte) (int, error)

func (*LogSyncContentValue_FullSyncResponse) SizeVT added in v0.9.0 

func (m *LogSyncContentValue_FullSyncResponse) SizeVT() (n int)

type LogSyncContentValue_HeadUpdate added in v0.2.15 

type LogSyncContentValue_HeadUpdate struct {
	HeadUpdate *LogHeadUpdate `protobuf:"bytes,1,opt,name=headUpdate,proto3,oneof"`
}

func (*LogSyncContentValue_HeadUpdate) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogSyncContentValue_HeadUpdate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogSyncContentValue_HeadUpdate) MarshalToVT added in v0.9.0 

func (m *LogSyncContentValue_HeadUpdate) MarshalToVT(dAtA []byte) (int, error)

func (*LogSyncContentValue_HeadUpdate) SizeVT added in v0.9.0 

func (m *LogSyncContentValue_HeadUpdate) SizeVT() (n int)

type LogSyncMessage added in v0.2.15 

type LogSyncMessage struct {
	Id      string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Payload []byte               `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Content *LogSyncContentValue `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

LogSyncMessage is a message sent when we are syncing logs

func WrapFullRequest added in v0.2.15 

func WrapFullRequest(request *LogFullSyncRequest, rootRecord *RawRecordWithId) *LogSyncMessage

func WrapFullResponse added in v0.2.15 

func WrapFullResponse(response *LogFullSyncResponse, rootRecord *RawRecordWithId) *LogSyncMessage

func WrapHeadUpdate added in v0.2.15 

func WrapHeadUpdate(update *LogHeadUpdate, rootRecord *RawRecordWithId) *LogSyncMessage

func (*LogSyncMessage) Descriptor deprecated added in v0.2.15 

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

Deprecated: Use LogSyncMessage.ProtoReflect.Descriptor instead.

func (*LogSyncMessage) GetContent added in v0.2.15 

func (x *LogSyncMessage) GetContent() *LogSyncContentValue

func (*LogSyncMessage) GetId added in v0.2.15 

func (x *LogSyncMessage) GetId() string

func (*LogSyncMessage) GetPayload added in v0.2.15 

func (x *LogSyncMessage) GetPayload() []byte

func (*LogSyncMessage) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogSyncMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogSyncMessage) MarshalToVT added in v0.9.0 

func (m *LogSyncMessage) MarshalToVT(dAtA []byte) (int, error)

func (*LogSyncMessage) MarshalVT added in v0.9.0 

func (m *LogSyncMessage) MarshalVT() (dAtA []byte, err error)

func (*LogSyncMessage) ProtoMessage added in v0.2.15 

func (*LogSyncMessage) ProtoMessage()

func (*LogSyncMessage) ProtoReflect added in v0.9.0 

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

func (*LogSyncMessage) Reset added in v0.2.15 

func (x *LogSyncMessage) Reset()

func (*LogSyncMessage) SizeVT added in v0.9.0 

func (m *LogSyncMessage) SizeVT() (n int)

func (*LogSyncMessage) String added in v0.2.15 

func (x *LogSyncMessage) String() string

func (*LogSyncMessage) UnmarshalVT added in v0.9.0 

func (m *LogSyncMessage) UnmarshalVT(dAtA []byte) error

type LogWatchEvent 

type LogWatchEvent struct {
	LogId   string             `protobuf:"bytes,1,opt,name=logId,proto3" json:"logId,omitempty"`
	Records []*RawRecordWithId `protobuf:"bytes,2,rep,name=records,proto3" json:"records,omitempty"`
	Error   *Err               `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*LogWatchEvent) Descriptor deprecated 

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

Deprecated: Use LogWatchEvent.ProtoReflect.Descriptor instead.

func (*LogWatchEvent) GetError 

func (x *LogWatchEvent) GetError() *Err

func (*LogWatchEvent) GetLogId 

func (x *LogWatchEvent) GetLogId() string

func (*LogWatchEvent) GetRecords 

func (x *LogWatchEvent) GetRecords() []*RawRecordWithId

func (*LogWatchEvent) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogWatchEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogWatchEvent) MarshalToVT added in v0.9.0 

func (m *LogWatchEvent) MarshalToVT(dAtA []byte) (int, error)

func (*LogWatchEvent) MarshalVT added in v0.9.0 

func (m *LogWatchEvent) MarshalVT() (dAtA []byte, err error)

func (*LogWatchEvent) ProtoMessage 

func (*LogWatchEvent) ProtoMessage()

func (*LogWatchEvent) ProtoReflect added in v0.9.0 

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

func (*LogWatchEvent) Reset 

func (x *LogWatchEvent) Reset()

func (*LogWatchEvent) SizeVT added in v0.9.0 

func (m *LogWatchEvent) SizeVT() (n int)

func (*LogWatchEvent) String 

func (x *LogWatchEvent) String() string

func (*LogWatchEvent) UnmarshalVT added in v0.9.0 

func (m *LogWatchEvent) UnmarshalVT(dAtA []byte) error

type LogWatchRequest 

type LogWatchRequest struct {
	WatchIds   []string `protobuf:"bytes,1,rep,name=watchIds,proto3" json:"watchIds,omitempty"`
	UnwatchIds []string `protobuf:"bytes,2,rep,name=unwatchIds,proto3" json:"unwatchIds,omitempty"`
	// contains filtered or unexported fields
}

func (*LogWatchRequest) Descriptor deprecated 

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

Deprecated: Use LogWatchRequest.ProtoReflect.Descriptor instead.

func (*LogWatchRequest) GetUnwatchIds 

func (x *LogWatchRequest) GetUnwatchIds() []string

func (*LogWatchRequest) GetWatchIds 

func (x *LogWatchRequest) GetWatchIds() []string

func (*LogWatchRequest) MarshalToSizedBufferVT added in v0.9.0 

func (m *LogWatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LogWatchRequest) MarshalToVT added in v0.9.0 

func (m *LogWatchRequest) MarshalToVT(dAtA []byte) (int, error)

func (*LogWatchRequest) MarshalVT added in v0.9.0 

func (m *LogWatchRequest) MarshalVT() (dAtA []byte, err error)

func (*LogWatchRequest) ProtoMessage 

func (*LogWatchRequest) ProtoMessage()

func (*LogWatchRequest) ProtoReflect added in v0.9.0 

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

func (*LogWatchRequest) Reset 

func (x *LogWatchRequest) Reset()

func (*LogWatchRequest) SizeVT added in v0.9.0 

func (m *LogWatchRequest) SizeVT() (n int)

func (*LogWatchRequest) String 

func (x *LogWatchRequest) String() string

func (*LogWatchRequest) UnmarshalVT added in v0.9.0 

func (m *LogWatchRequest) UnmarshalVT(dAtA []byte) error

type Ok 

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

func (*Ok) Descriptor deprecated 

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

Deprecated: Use Ok.ProtoReflect.Descriptor instead.

func (*Ok) MarshalToSizedBufferVT added in v0.9.0 

func (m *Ok) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Ok) MarshalToVT added in v0.9.0 

func (m *Ok) MarshalToVT(dAtA []byte) (int, error)

func (*Ok) MarshalVT added in v0.9.0 

func (m *Ok) MarshalVT() (dAtA []byte, err error)

func (*Ok) ProtoMessage 

func (*Ok) ProtoMessage()

func (*Ok) ProtoReflect added in v0.9.0 

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

func (*Ok) Reset 

func (x *Ok) Reset()

func (*Ok) SizeVT added in v0.9.0 

func (m *Ok) SizeVT() (n int)

func (*Ok) String 

func (x *Ok) String() string

func (*Ok) UnmarshalVT added in v0.9.0 

func (m *Ok) UnmarshalVT(dAtA []byte) error

type RawRecord 

type RawRecord struct {
	Payload           []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Signature         []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	AcceptorIdentity  []byte `protobuf:"bytes,3,opt,name=acceptorIdentity,proto3" json:"acceptorIdentity,omitempty"`
	AcceptorSignature []byte `protobuf:"bytes,4,opt,name=acceptorSignature,proto3" json:"acceptorSignature,omitempty"`
	AcceptorTimestamp int64  `protobuf:"varint,5,opt,name=acceptorTimestamp,proto3" json:"acceptorTimestamp,omitempty"`
	// contains filtered or unexported fields
}

RawRecord is a proto message containing the payload in bytes, signature of the account who added it and signature of the acceptor

func (*RawRecord) Descriptor deprecated 

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

Deprecated: Use RawRecord.ProtoReflect.Descriptor instead.

func (*RawRecord) GetAcceptorIdentity 

func (x *RawRecord) GetAcceptorIdentity() []byte

func (*RawRecord) GetAcceptorSignature 

func (x *RawRecord) GetAcceptorSignature() []byte

func (*RawRecord) GetAcceptorTimestamp added in v0.2.17 

func (x *RawRecord) GetAcceptorTimestamp() int64

func (*RawRecord) GetPayload 

func (x *RawRecord) GetPayload() []byte

func (*RawRecord) GetSignature 

func (x *RawRecord) GetSignature() []byte

func (*RawRecord) MarshalToSizedBufferVT added in v0.9.0 

func (m *RawRecord) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RawRecord) MarshalToVT added in v0.9.0 

func (m *RawRecord) MarshalToVT(dAtA []byte) (int, error)

func (*RawRecord) MarshalVT added in v0.9.0 

func (m *RawRecord) MarshalVT() (dAtA []byte, err error)

func (*RawRecord) ProtoMessage 

func (*RawRecord) ProtoMessage()

func (*RawRecord) ProtoReflect added in v0.9.0 

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

func (*RawRecord) Reset 

func (x *RawRecord) Reset()

func (*RawRecord) SizeVT added in v0.9.0 

func (m *RawRecord) SizeVT() (n int)

func (*RawRecord) String 

func (x *RawRecord) String() string

func (*RawRecord) UnmarshalVT added in v0.9.0 

func (m *RawRecord) UnmarshalVT(dAtA []byte) error

type RawRecordWithId 

type RawRecordWithId struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Id      string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

RawRecordWithId is a raw record and the id for convenience

func (*RawRecordWithId) Descriptor deprecated 

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

Deprecated: Use RawRecordWithId.ProtoReflect.Descriptor instead.

func (*RawRecordWithId) GetId 

func (x *RawRecordWithId) GetId() string

func (*RawRecordWithId) GetPayload 

func (x *RawRecordWithId) GetPayload() []byte

func (*RawRecordWithId) MarshalToSizedBufferVT added in v0.9.0 

func (m *RawRecordWithId) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RawRecordWithId) MarshalToVT added in v0.9.0 

func (m *RawRecordWithId) MarshalToVT(dAtA []byte) (int, error)

func (*RawRecordWithId) MarshalVT added in v0.9.0 

func (m *RawRecordWithId) MarshalVT() (dAtA []byte, err error)

func (*RawRecordWithId) ProtoMessage 

func (*RawRecordWithId) ProtoMessage()

func (*RawRecordWithId) ProtoReflect added in v0.9.0 

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

func (*RawRecordWithId) Reset 

func (x *RawRecordWithId) Reset()

func (*RawRecordWithId) SizeVT added in v0.9.0 

func (m *RawRecordWithId) SizeVT() (n int)

func (*RawRecordWithId) String 

func (x *RawRecordWithId) String() string

func (*RawRecordWithId) UnmarshalVT added in v0.9.0 

func (m *RawRecordWithId) UnmarshalVT(dAtA []byte) error

type Record 

type Record struct {
	PrevId    string `protobuf:"bytes,1,opt,name=prevId,proto3" json:"prevId,omitempty"`
	Identity  []byte `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Record is a record containing a data

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetData 

func (x *Record) GetData() []byte

func (*Record) GetIdentity 

func (x *Record) GetIdentity() []byte

func (*Record) GetPrevId 

func (x *Record) GetPrevId() string

func (*Record) GetTimestamp 

func (x *Record) GetTimestamp() int64

func (*Record) MarshalToSizedBufferVT added in v0.9.0 

func (m *Record) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Record) MarshalToVT added in v0.9.0 

func (m *Record) MarshalToVT(dAtA []byte) (int, error)

func (*Record) MarshalVT added in v0.9.0 

func (m *Record) MarshalVT() (dAtA []byte, err error)

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect added in v0.9.0 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) SizeVT added in v0.9.0 

func (m *Record) SizeVT() (n int)

func (*Record) String 

func (x *Record) String() string

func (*Record) UnmarshalVT added in v0.9.0 

func (m *Record) UnmarshalVT(dAtA []byte) error

type RecordAddRequest 

type RecordAddRequest struct {
	LogId  string     `protobuf:"bytes,1,opt,name=logId,proto3" json:"logId,omitempty"`
	Record *RawRecord `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordAddRequest) Descriptor deprecated 

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

Deprecated: Use RecordAddRequest.ProtoReflect.Descriptor instead.

func (*RecordAddRequest) GetLogId 

func (x *RecordAddRequest) GetLogId() string

func (*RecordAddRequest) GetRecord 

func (x *RecordAddRequest) GetRecord() *RawRecord

func (*RecordAddRequest) MarshalToSizedBufferVT added in v0.9.0 

func (m *RecordAddRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RecordAddRequest) MarshalToVT added in v0.9.0 

func (m *RecordAddRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RecordAddRequest) MarshalVT added in v0.9.0 

func (m *RecordAddRequest) MarshalVT() (dAtA []byte, err error)

func (*RecordAddRequest) ProtoMessage 

func (*RecordAddRequest) ProtoMessage()

func (*RecordAddRequest) ProtoReflect added in v0.9.0 

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

func (*RecordAddRequest) Reset 

func (x *RecordAddRequest) Reset()

func (*RecordAddRequest) SizeVT added in v0.9.0 

func (m *RecordAddRequest) SizeVT() (n int)

func (*RecordAddRequest) String 

func (x *RecordAddRequest) String() string

func (*RecordAddRequest) UnmarshalVT added in v0.9.0 

func (m *RecordAddRequest) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.