batchfetcherpb

Documentation

Index

• Variables
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetClientProgress() *commonpb.ClientProgress
  • func (x *Event) GetNewOrderedBatch() *NewOrderedBatch
  • func (m *Event) GetType() isEvent_Type
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (*Event) ReflectTypeOptions() []reflect.Type
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type Event_ClientProgress
  • func (w *Event_ClientProgress) Unwrap() *commonpb.ClientProgress
• type Event_NewOrderedBatch
  • func (w *Event_NewOrderedBatch) Unwrap() *NewOrderedBatch
• type Event_Type
• type Event_TypeWrapper
• type NewOrderedBatch
  • func (*NewOrderedBatch) Descriptor() ([]byte, []int)
  • func (x *NewOrderedBatch) GetTxs() []*requestpb.Request
  • func (*NewOrderedBatch) ProtoMessage()
  • func (x *NewOrderedBatch) ProtoReflect() protoreflect.Message
  • func (x *NewOrderedBatch) Reset()
  • func (x *NewOrderedBatch) String() string

Variables

var File_batchfetcherpb_batchfetcherpb_proto protoreflect.FileDescriptor

Types

type Event

type Event struct {

	// Types that are assignable to Type:
	//	*Event_NewOrderedBatch
	//	*Event_ClientProgress
	Type isEvent_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetClientProgress

func (x *Event) GetClientProgress() *commonpb.ClientProgress

func (*Event) GetNewOrderedBatch

func (x *Event) GetNewOrderedBatch() *NewOrderedBatch

func (*Event) GetType

func (m *Event) GetType() isEvent_Type

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) ReflectTypeOptions

func (*Event) ReflectTypeOptions() []reflect.Type

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type Event_ClientProgress

type Event_ClientProgress struct {
	ClientProgress *commonpb.ClientProgress `protobuf:"bytes,2,opt,name=client_progress,json=clientProgress,proto3,oneof"`
}

func (*Event_ClientProgress) Unwrap

func (w *Event_ClientProgress) Unwrap() *commonpb.ClientProgress

type Event_NewOrderedBatch

type Event_NewOrderedBatch struct {
	NewOrderedBatch *NewOrderedBatch `protobuf:"bytes,1,opt,name=new_ordered_batch,json=newOrderedBatch,proto3,oneof"`
}

func (*Event_NewOrderedBatch) Unwrap

func (w *Event_NewOrderedBatch) Unwrap() *NewOrderedBatch

type Event_Type

type Event_Type = isEvent_Type

type Event_TypeWrapper

type Event_TypeWrapper[T any] interface {
	Event_Type
	Unwrap() *T
}

type NewOrderedBatch

type NewOrderedBatch struct {
	Txs []*requestpb.Request `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	// contains filtered or unexported fields
}

func (*NewOrderedBatch) Descriptor

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

Deprecated: Use NewOrderedBatch.ProtoReflect.Descriptor instead.

func (*NewOrderedBatch) GetTxs

func (x *NewOrderedBatch) GetTxs() []*requestpb.Request

func (*NewOrderedBatch) ProtoMessage

func (*NewOrderedBatch) ProtoMessage()

func (*NewOrderedBatch) ProtoReflect

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

func (*NewOrderedBatch) Reset

func (x *NewOrderedBatch) Reset()

func (*NewOrderedBatch) String

func (x *NewOrderedBatch) String() string