eventpb

package
v0.0.0-...-bd4e2c0 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_eventpb_eventpb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AnnounceDummyBatch 

type AnnounceDummyBatch struct {
	Sn    uint64           `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Batch *requestpb.Batch `protobuf:"bytes,2,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*AnnounceDummyBatch) Descriptor deprecated 

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

Deprecated: Use AnnounceDummyBatch.ProtoReflect.Descriptor instead.

func (*AnnounceDummyBatch) GetBatch 

func (x *AnnounceDummyBatch) GetBatch() *requestpb.Batch

func (*AnnounceDummyBatch) GetSn 

func (x *AnnounceDummyBatch) GetSn() uint64

func (*AnnounceDummyBatch) ProtoMessage 

func (*AnnounceDummyBatch) ProtoMessage()

func (*AnnounceDummyBatch) ProtoReflect 

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

func (*AnnounceDummyBatch) Reset 

func (x *AnnounceDummyBatch) Reset()

func (*AnnounceDummyBatch) String 

func (x *AnnounceDummyBatch) String() string

type AppSnapshot 

type AppSnapshot struct {
	Sn   uint64 `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AppSnapshot) Descriptor deprecated 

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

Deprecated: Use AppSnapshot.ProtoReflect.Descriptor instead.

func (*AppSnapshot) GetData 

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

func (*AppSnapshot) GetSn 

func (x *AppSnapshot) GetSn() uint64

func (*AppSnapshot) ProtoMessage 

func (*AppSnapshot) ProtoMessage()

func (*AppSnapshot) ProtoReflect 

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

func (*AppSnapshot) Reset 

func (x *AppSnapshot) Reset()

func (*AppSnapshot) String 

func (x *AppSnapshot) String() string

type AppSnapshotRequest 

type AppSnapshotRequest struct {
	Sn uint64 `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	// contains filtered or unexported fields
}

func (*AppSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use AppSnapshotRequest.ProtoReflect.Descriptor instead.

func (*AppSnapshotRequest) GetSn 

func (x *AppSnapshotRequest) GetSn() uint64

func (*AppSnapshotRequest) ProtoMessage 

func (*AppSnapshotRequest) ProtoMessage()

func (*AppSnapshotRequest) ProtoReflect 

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

func (*AppSnapshotRequest) Reset 

func (x *AppSnapshotRequest) Reset()

func (*AppSnapshotRequest) String 

func (x *AppSnapshotRequest) String() string

type Deliver 

type Deliver struct {
	Sn    uint64           `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Batch *requestpb.Batch `protobuf:"bytes,2,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*Deliver) Descriptor deprecated 

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

Deprecated: Use Deliver.ProtoReflect.Descriptor instead.

func (*Deliver) GetBatch 

func (x *Deliver) GetBatch() *requestpb.Batch

func (*Deliver) GetSn 

func (x *Deliver) GetSn() uint64

func (*Deliver) ProtoMessage 

func (*Deliver) ProtoMessage()

func (*Deliver) ProtoReflect 

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

func (*Deliver) Reset 

func (x *Deliver) Reset()

func (*Deliver) String 

func (x *Deliver) String() string

type Event 

type Event struct {

	// TODO, normalize naming, for instance Complete/Completed
	//
	// Types that are assignable to Type:
	//	*Event_Init
	//	*Event_Tick
	//	*Event_WalAppend
	//	*Event_WalEntry
	//	*Event_WalTruncate
	//	*Event_Request
	//	*Event_HashRequest
	//	*Event_HashResult
	//	*Event_RequestReady
	//	*Event_SendMessage
	//	*Event_MessageReceived
	//	*Event_Deliver
	//	*Event_Iss
	//	*Event_VerifyRequestSig
	//	*Event_RequestSigVerified
	//	*Event_StoreVerifiedRequest
	//	*Event_AppSnapshotRequest
	//	*Event_AppSnapshot
	//	*Event_PersistDummyBatch
	//	*Event_AnnounceDummyBatch
	//	*Event_StoreDummyRequest
	Type isEvent_Type `protobuf_oneof:"type"`
	// A list of follow-up events to process after this event has been processed.
	// This field is used if events need to be processed in a particular order.
	// For example, a message sending event must only be processed
	// after the corresponding entry has been persisted in the write-ahead log (WAL).
	// In this case, the WAL append event would be this event
	// and the next field would contain the message sending event.
	Next []*Event `protobuf:"bytes,100,rep,name=next,proto3" json:"next,omitempty"`
	// contains filtered or unexported fields
}

Event represents a state event to be injected into the state machine

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) FollowUp 

func (e *Event) FollowUp(next *Event) *Event

FollowUp appends the Event next as a follow-up Event to this Event and returns the next Event (the argument). FollowUp can be called multiple times on the same Event and all the Events added this way will be guaranteed to be applied after this Event. The appended Events are, however, not guaranteed to be applied in any order relative to each other. Events (e.g., e1, e3, e3) that should be applied one after the other can be chained using chained calls to FollowUp: e1.FollowUp(e2).FollowUp(e3) guarantees application in this order. Note that the above expression evaluates to e3 and thus applying the whole expression will only evaluate e3. To process all three Events, e1 (and only e1) must be added to the Node's WorkItems.

func (*Event) FollowUps 

func (e *Event) FollowUps(next []*Event)

FollowUps is like FollowUp, but appends multiple Events and does not return anything (and thus cannot be chained). e.FollowUps([]*Event{e1, e2, e3}) is equivalent to e.FollowUp(e1); e.FollowUp(e2); e.FollowUp(e3)

func (*Event) GetAnnounceDummyBatch 

func (x *Event) GetAnnounceDummyBatch() *AnnounceDummyBatch

func (*Event) GetAppSnapshot 

func (x *Event) GetAppSnapshot() *AppSnapshot

func (*Event) GetAppSnapshotRequest 

func (x *Event) GetAppSnapshotRequest() *AppSnapshotRequest

func (*Event) GetDeliver 

func (x *Event) GetDeliver() *Deliver

func (*Event) GetHashRequest 

func (x *Event) GetHashRequest() *HashRequest

func (*Event) GetHashResult 

func (x *Event) GetHashResult() *HashResult

func (*Event) GetInit 

func (x *Event) GetInit() *Init

func (*Event) GetIss 

func (x *Event) GetIss() *isspb.ISSEvent

func (*Event) GetMessageReceived 

func (x *Event) GetMessageReceived() *MessageReceived

func (*Event) GetNext 

func (x *Event) GetNext() []*Event

func (*Event) GetPersistDummyBatch 

func (x *Event) GetPersistDummyBatch() *PersistDummyBatch

func (*Event) GetRequest 

func (x *Event) GetRequest() *requestpb.Request

func (*Event) GetRequestReady 

func (x *Event) GetRequestReady() *RequestReady

func (*Event) GetRequestSigVerified 

func (x *Event) GetRequestSigVerified() *RequestSigVerified

func (*Event) GetSendMessage 

func (x *Event) GetSendMessage() *SendMessage

func (*Event) GetStoreDummyRequest 

func (x *Event) GetStoreDummyRequest() *StoreDummyRequest

func (*Event) GetStoreVerifiedRequest 

func (x *Event) GetStoreVerifiedRequest() *StoreVerifiedRequest

func (*Event) GetTick 

func (x *Event) GetTick() *Tick

func (*Event) GetType 

func (m *Event) GetType() isEvent_Type

func (*Event) GetVerifyRequestSig 

func (x *Event) GetVerifyRequestSig() *VerifyRequestSig

func (*Event) GetWalAppend 

func (x *Event) GetWalAppend() *WALAppend

func (*Event) GetWalEntry 

func (x *Event) GetWalEntry() *WALEntry

func (*Event) GetWalTruncate 

func (x *Event) GetWalTruncate() *WALTruncate

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_AnnounceDummyBatch 

type Event_AnnounceDummyBatch struct {
	AnnounceDummyBatch *AnnounceDummyBatch `protobuf:"bytes,102,opt,name=announce_dummy_batch,json=announceDummyBatch,proto3,oneof"`
}

type Event_AppSnapshot 

type Event_AppSnapshot struct {
	AppSnapshot *AppSnapshot `protobuf:"bytes,18,opt,name=app_snapshot,json=appSnapshot,proto3,oneof"`
}

type Event_AppSnapshotRequest 

type Event_AppSnapshotRequest struct {
	AppSnapshotRequest *AppSnapshotRequest `protobuf:"bytes,17,opt,name=app_snapshot_request,json=appSnapshotRequest,proto3,oneof"`
}

type Event_Deliver 

type Event_Deliver struct {
	Deliver *Deliver `protobuf:"bytes,12,opt,name=deliver,proto3,oneof"`
}

type Event_HashRequest 

type Event_HashRequest struct {
	HashRequest *HashRequest `protobuf:"bytes,7,opt,name=hash_request,json=hashRequest,proto3,oneof"`
}

type Event_HashResult 

type Event_HashResult struct {
	HashResult *HashResult `protobuf:"bytes,8,opt,name=hash_result,json=hashResult,proto3,oneof"`
}

type Event_Init 

type Event_Init struct {
	Init *Init `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type Event_Iss 

type Event_Iss struct {
	Iss *isspb.ISSEvent `protobuf:"bytes,13,opt,name=iss,proto3,oneof"`
}

type Event_MessageReceived 

type Event_MessageReceived struct {
	MessageReceived *MessageReceived `protobuf:"bytes,11,opt,name=message_received,json=messageReceived,proto3,oneof"`
}

type Event_PersistDummyBatch 

type Event_PersistDummyBatch struct {
	// Dummy events for testing purposes only.
	PersistDummyBatch *PersistDummyBatch `protobuf:"bytes,101,opt,name=persist_dummy_batch,json=persistDummyBatch,proto3,oneof"`
}

type Event_Request 

type Event_Request struct {
	Request *requestpb.Request `protobuf:"bytes,6,opt,name=request,proto3,oneof"`
}

type Event_RequestReady 

type Event_RequestReady struct {
	RequestReady *RequestReady `protobuf:"bytes,9,opt,name=request_ready,json=requestReady,proto3,oneof"`
}

type Event_RequestSigVerified 

type Event_RequestSigVerified struct {
	RequestSigVerified *RequestSigVerified `protobuf:"bytes,15,opt,name=request_sig_verified,json=requestSigVerified,proto3,oneof"`
}

type Event_SendMessage 

type Event_SendMessage struct {
	SendMessage *SendMessage `protobuf:"bytes,10,opt,name=send_message,json=sendMessage,proto3,oneof"`
}

type Event_StoreDummyRequest 

type Event_StoreDummyRequest struct {
	StoreDummyRequest *StoreDummyRequest `protobuf:"bytes,103,opt,name=store_dummy_request,json=storeDummyRequest,proto3,oneof"`
}

type Event_StoreVerifiedRequest 

type Event_StoreVerifiedRequest struct {
	StoreVerifiedRequest *StoreVerifiedRequest `protobuf:"bytes,16,opt,name=store_verified_request,json=storeVerifiedRequest,proto3,oneof"`
}

type Event_Tick 

type Event_Tick struct {
	Tick *Tick `protobuf:"bytes,2,opt,name=tick,proto3,oneof"`
}

type Event_VerifyRequestSig 

type Event_VerifyRequestSig struct {
	VerifyRequestSig *VerifyRequestSig `protobuf:"bytes,14,opt,name=verify_request_sig,json=verifyRequestSig,proto3,oneof"`
}

type Event_WalAppend 

type Event_WalAppend struct {
	WalAppend *WALAppend `protobuf:"bytes,3,opt,name=wal_append,json=walAppend,proto3,oneof"`
}

type Event_WalEntry 

type Event_WalEntry struct {
	WalEntry *WALEntry `protobuf:"bytes,4,opt,name=wal_entry,json=walEntry,proto3,oneof"`
}

type Event_WalTruncate 

type Event_WalTruncate struct {
	WalTruncate *WALTruncate `protobuf:"bytes,5,opt,name=wal_truncate,json=walTruncate,proto3,oneof"`
}

type HashOrigin 

type HashOrigin struct {

	// Types that are assignable to Type:
	//	*HashOrigin_Request
	//	*HashOrigin_Iss
	Type isHashOrigin_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*HashOrigin) Descriptor deprecated 

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

Deprecated: Use HashOrigin.ProtoReflect.Descriptor instead.

func (*HashOrigin) GetIss 

func (x *HashOrigin) GetIss() *isspb.ISSHashOrigin

func (*HashOrigin) GetRequest 

func (x *HashOrigin) GetRequest() *requestpb.Request

func (*HashOrigin) GetType 

func (m *HashOrigin) GetType() isHashOrigin_Type

func (*HashOrigin) ProtoMessage 

func (*HashOrigin) ProtoMessage()

func (*HashOrigin) ProtoReflect 

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

func (*HashOrigin) Reset 

func (x *HashOrigin) Reset()

func (*HashOrigin) String 

func (x *HashOrigin) String() string

type HashOrigin_Iss 

type HashOrigin_Iss struct {
	Iss *isspb.ISSHashOrigin `protobuf:"bytes,2,opt,name=iss,proto3,oneof"`
}

type HashOrigin_Request 

type HashOrigin_Request struct {
	Request *requestpb.Request `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type HashRequest 

type HashRequest struct {
	Data   [][]byte    `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Origin *HashOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*HashRequest) Descriptor deprecated 

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

Deprecated: Use HashRequest.ProtoReflect.Descriptor instead.

func (*HashRequest) GetData 

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

func (*HashRequest) GetOrigin 

func (x *HashRequest) GetOrigin() *HashOrigin

func (*HashRequest) ProtoMessage 

func (*HashRequest) ProtoMessage()

func (*HashRequest) ProtoReflect 

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

func (*HashRequest) Reset 

func (x *HashRequest) Reset()

func (*HashRequest) String 

func (x *HashRequest) String() string

type HashResult 

type HashResult struct {
	Digest []byte      `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	Origin *HashOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*HashResult) Descriptor deprecated 

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

Deprecated: Use HashResult.ProtoReflect.Descriptor instead.

func (*HashResult) GetDigest 

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

func (*HashResult) GetOrigin 

func (x *HashResult) GetOrigin() *HashOrigin

func (*HashResult) ProtoMessage 

func (*HashResult) ProtoMessage()

func (*HashResult) ProtoReflect 

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

func (*HashResult) Reset 

func (x *HashResult) Reset()

func (*HashResult) String 

func (x *HashResult) String() string

type Init 

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

func (*Init) Descriptor deprecated 

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

Deprecated: Use Init.ProtoReflect.Descriptor instead.

func (*Init) ProtoMessage 

func (*Init) ProtoMessage()

func (*Init) ProtoReflect 

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

func (*Init) Reset 

func (x *Init) Reset()

func (*Init) String 

func (x *Init) String() string

type MessageReceived 

type MessageReceived struct {
	From uint64             `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	Msg  *messagepb.Message `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageReceived) Descriptor deprecated 

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

Deprecated: Use MessageReceived.ProtoReflect.Descriptor instead.

func (*MessageReceived) GetFrom 

func (x *MessageReceived) GetFrom() uint64

func (*MessageReceived) GetMsg 

func (x *MessageReceived) GetMsg() *messagepb.Message

func (*MessageReceived) ProtoMessage 

func (*MessageReceived) ProtoMessage()

func (*MessageReceived) ProtoReflect 

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

func (*MessageReceived) Reset 

func (x *MessageReceived) Reset()

func (*MessageReceived) String 

func (x *MessageReceived) String() string

type PersistDummyBatch 

type PersistDummyBatch struct {
	Sn    uint64           `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Batch *requestpb.Batch `protobuf:"bytes,2,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*PersistDummyBatch) Descriptor deprecated 

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

Deprecated: Use PersistDummyBatch.ProtoReflect.Descriptor instead.

func (*PersistDummyBatch) GetBatch 

func (x *PersistDummyBatch) GetBatch() *requestpb.Batch

func (*PersistDummyBatch) GetSn 

func (x *PersistDummyBatch) GetSn() uint64

func (*PersistDummyBatch) ProtoMessage 

func (*PersistDummyBatch) ProtoMessage()

func (*PersistDummyBatch) ProtoReflect 

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

func (*PersistDummyBatch) Reset 

func (x *PersistDummyBatch) Reset()

func (*PersistDummyBatch) String 

func (x *PersistDummyBatch) String() string

type RequestReady 

type RequestReady struct {
	RequestRef *requestpb.RequestRef `protobuf:"bytes,1,opt,name=request_ref,json=requestRef,proto3" json:"request_ref,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestReady) Descriptor deprecated 

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

Deprecated: Use RequestReady.ProtoReflect.Descriptor instead.

func (*RequestReady) GetRequestRef 

func (x *RequestReady) GetRequestRef() *requestpb.RequestRef

func (*RequestReady) ProtoMessage 

func (*RequestReady) ProtoMessage()

func (*RequestReady) ProtoReflect 

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

func (*RequestReady) Reset 

func (x *RequestReady) Reset()

func (*RequestReady) String 

func (x *RequestReady) String() string

type RequestSigVerified 

type RequestSigVerified struct {
	RequestRef *requestpb.RequestRef `protobuf:"bytes,1,opt,name=request_ref,json=requestRef,proto3" json:"request_ref,omitempty"`
	Valid      bool                  `protobuf:"varint,2,opt,name=valid,proto3" json:"valid,omitempty"`
	Error      string                `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestSigVerified) Descriptor deprecated 

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

Deprecated: Use RequestSigVerified.ProtoReflect.Descriptor instead.

func (*RequestSigVerified) GetError 

func (x *RequestSigVerified) GetError() string

func (*RequestSigVerified) GetRequestRef 

func (x *RequestSigVerified) GetRequestRef() *requestpb.RequestRef

func (*RequestSigVerified) GetValid 

func (x *RequestSigVerified) GetValid() bool

func (*RequestSigVerified) ProtoMessage 

func (*RequestSigVerified) ProtoMessage()

func (*RequestSigVerified) ProtoReflect 

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

func (*RequestSigVerified) Reset 

func (x *RequestSigVerified) Reset()

func (*RequestSigVerified) String 

func (x *RequestSigVerified) String() string

type SendMessage 

type SendMessage struct {
	Destinations []uint64           `protobuf:"varint,1,rep,packed,name=destinations,proto3" json:"destinations,omitempty"`
	Msg          *messagepb.Message `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessage) Descriptor deprecated 

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

Deprecated: Use SendMessage.ProtoReflect.Descriptor instead.

func (*SendMessage) GetDestinations 

func (x *SendMessage) GetDestinations() []uint64

func (*SendMessage) GetMsg 

func (x *SendMessage) GetMsg() *messagepb.Message

func (*SendMessage) ProtoMessage 

func (*SendMessage) ProtoMessage()

func (*SendMessage) ProtoReflect 

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

func (*SendMessage) Reset 

func (x *SendMessage) Reset()

func (*SendMessage) String 

func (x *SendMessage) String() string

type StoreDummyRequest 

type StoreDummyRequest struct {
	RequestRef *requestpb.RequestRef `protobuf:"bytes,1,opt,name=request_ref,json=requestRef,proto3" json:"request_ref,omitempty"`
	Data       []byte                `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreDummyRequest) Descriptor deprecated 

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

Deprecated: Use StoreDummyRequest.ProtoReflect.Descriptor instead.

func (*StoreDummyRequest) GetData 

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

func (*StoreDummyRequest) GetRequestRef 

func (x *StoreDummyRequest) GetRequestRef() *requestpb.RequestRef

func (*StoreDummyRequest) ProtoMessage 

func (*StoreDummyRequest) ProtoMessage()

func (*StoreDummyRequest) ProtoReflect 

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

func (*StoreDummyRequest) Reset 

func (x *StoreDummyRequest) Reset()

func (*StoreDummyRequest) String 

func (x *StoreDummyRequest) String() string

type StoreVerifiedRequest 

type StoreVerifiedRequest struct {
	RequestRef    *requestpb.RequestRef `protobuf:"bytes,1,opt,name=request_ref,json=requestRef,proto3" json:"request_ref,omitempty"`
	Data          []byte                `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Authenticator []byte                `protobuf:"bytes,3,opt,name=authenticator,proto3" json:"authenticator,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreVerifiedRequest) Descriptor deprecated 

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

Deprecated: Use StoreVerifiedRequest.ProtoReflect.Descriptor instead.

func (*StoreVerifiedRequest) GetAuthenticator 

func (x *StoreVerifiedRequest) GetAuthenticator() []byte

func (*StoreVerifiedRequest) GetData 

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

func (*StoreVerifiedRequest) GetRequestRef 

func (x *StoreVerifiedRequest) GetRequestRef() *requestpb.RequestRef

func (*StoreVerifiedRequest) ProtoMessage 

func (*StoreVerifiedRequest) ProtoMessage()

func (*StoreVerifiedRequest) ProtoReflect 

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

func (*StoreVerifiedRequest) Reset 

func (x *StoreVerifiedRequest) Reset()

func (*StoreVerifiedRequest) String 

func (x *StoreVerifiedRequest) String() string

type Tick 

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

func (*Tick) Descriptor deprecated 

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

Deprecated: Use Tick.ProtoReflect.Descriptor instead.

func (*Tick) ProtoMessage 

func (*Tick) ProtoMessage()

func (*Tick) ProtoReflect 

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

func (*Tick) Reset 

func (x *Tick) Reset()

func (*Tick) String 

func (x *Tick) String() string

type VerifyRequestSig 

type VerifyRequestSig struct {
	RequestRef *requestpb.RequestRef `protobuf:"bytes,1,opt,name=request_ref,json=requestRef,proto3" json:"request_ref,omitempty"`
	Signature  []byte                `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyRequestSig) Descriptor deprecated 

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

Deprecated: Use VerifyRequestSig.ProtoReflect.Descriptor instead.

func (*VerifyRequestSig) GetRequestRef 

func (x *VerifyRequestSig) GetRequestRef() *requestpb.RequestRef

func (*VerifyRequestSig) GetSignature 

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

func (*VerifyRequestSig) ProtoMessage 

func (*VerifyRequestSig) ProtoMessage()

func (*VerifyRequestSig) ProtoReflect 

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

func (*VerifyRequestSig) Reset 

func (x *VerifyRequestSig) Reset()

func (*VerifyRequestSig) String 

func (x *VerifyRequestSig) String() string

type WALAppend 

type WALAppend struct {
	Event          *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	RetentionIndex uint64 `protobuf:"varint,2,opt,name=retention_index,json=retentionIndex,proto3" json:"retention_index,omitempty"`
	// contains filtered or unexported fields
}

func (*WALAppend) Descriptor deprecated 

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

Deprecated: Use WALAppend.ProtoReflect.Descriptor instead.

func (*WALAppend) GetEvent 

func (x *WALAppend) GetEvent() *Event

func (*WALAppend) GetRetentionIndex 

func (x *WALAppend) GetRetentionIndex() uint64

func (*WALAppend) ProtoMessage 

func (*WALAppend) ProtoMessage()

func (*WALAppend) ProtoReflect 

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

func (*WALAppend) Reset 

func (x *WALAppend) Reset()

func (*WALAppend) String 

func (x *WALAppend) String() string

type WALEntry 

type WALEntry struct {
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*WALEntry) Descriptor deprecated 

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

Deprecated: Use WALEntry.ProtoReflect.Descriptor instead.

func (*WALEntry) GetEvent 

func (x *WALEntry) GetEvent() *Event

func (*WALEntry) ProtoMessage 

func (*WALEntry) ProtoMessage()

func (*WALEntry) ProtoReflect 

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

func (*WALEntry) Reset 

func (x *WALEntry) Reset()

func (*WALEntry) String 

func (x *WALEntry) String() string

type WALTruncate 

type WALTruncate struct {
	RetentionIndex uint64 `protobuf:"varint,1,opt,name=retention_index,json=retentionIndex,proto3" json:"retention_index,omitempty"`
	// contains filtered or unexported fields
}

func (*WALTruncate) Descriptor deprecated 

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

Deprecated: Use WALTruncate.ProtoReflect.Descriptor instead.

func (*WALTruncate) GetRetentionIndex 

func (x *WALTruncate) GetRetentionIndex() uint64

func (*WALTruncate) ProtoMessage 

func (*WALTruncate) ProtoMessage()

func (*WALTruncate) ProtoReflect 

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

func (*WALTruncate) Reset 

func (x *WALTruncate) Reset()

func (*WALTruncate) String 

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