batcher

Documentation

Index

• type BlockBuilder
  • func NewBlockBuilder() *BlockBuilder
  • func (b *BlockBuilder) AddData(data *common.Envelope) *BlockBuilder
  • func (b *BlockBuilder) AddMetadata(index int, value []byte, signature []byte, signatureHeader []byte, ...) *BlockBuilder
  • func (b *BlockBuilder) Build() *common.Block
  • func (b *BlockBuilder) SetHeader(number uint64, previousHash, dataHash []byte) *BlockBuilder
• type ExecuteTasksRequestBuilder
  • func NewExecuteTasksRequestBuilder() *ExecuteTasksRequestBuilder
  • func (b *ExecuteTasksRequestBuilder) AddTask(task *fpb.Task) *ExecuteTasksRequestBuilder
  • func (b *ExecuteTasksRequestBuilder) Build() *fpb.ExecuteTasksRequest
  • func (b *ExecuteTasksRequestBuilder) Marshal() []byte
• type TaskBuilder
  • func NewTaskBuilder() *TaskBuilder
  • func (b *TaskBuilder) Build() *fpb.Task
  • func (b *TaskBuilder) SetArgs(args []string) *TaskBuilder
  • func (b *TaskBuilder) SetID(id string) *TaskBuilder
  • func (b *TaskBuilder) SetMethod(method string) *TaskBuilder

Types

type BlockBuilder

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

func NewBlockBuilder

func NewBlockBuilder() *BlockBuilder

func (*BlockBuilder) AddData

func (b *BlockBuilder) AddData(data *common.Envelope) *BlockBuilder

func (*BlockBuilder) AddMetadata

func (b *BlockBuilder) AddMetadata(index int, value []byte, signature []byte, signatureHeader []byte, identifierHeader []byte) *BlockBuilder

func (*BlockBuilder) Build

func (b *BlockBuilder) Build() *common.Block

func (*BlockBuilder) SetHeader

func (b *BlockBuilder) SetHeader(number uint64, previousHash, dataHash []byte) *BlockBuilder

type ExecuteTasksRequestBuilder

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

func NewExecuteTasksRequestBuilder

func NewExecuteTasksRequestBuilder() *ExecuteTasksRequestBuilder

func (*ExecuteTasksRequestBuilder) AddTask

func (b *ExecuteTasksRequestBuilder) AddTask(task *fpb.Task) *ExecuteTasksRequestBuilder

func (*ExecuteTasksRequestBuilder) Build

func (b *ExecuteTasksRequestBuilder) Build() *fpb.ExecuteTasksRequest

func (*ExecuteTasksRequestBuilder) Marshal

func (b *ExecuteTasksRequestBuilder) Marshal() []byte

type TaskBuilder

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

func NewTaskBuilder

func NewTaskBuilder() *TaskBuilder

func (*TaskBuilder) Build

func (b *TaskBuilder) Build() *fpb.Task

func (*TaskBuilder) SetArgs

func (b *TaskBuilder) SetArgs(args []string) *TaskBuilder

func (*TaskBuilder) SetID

func (b *TaskBuilder) SetID(id string) *TaskBuilder

func (*TaskBuilder) SetMethod

func (b *TaskBuilder) SetMethod(method string) *TaskBuilder