pbfirehose

type ForkStep int32

type Request struct {

	// Controls where the stream of blocks will start.
	//
	// The stream will start **inclusively** at the requested block num.
	//
	// When not provided, starts at first streamable block of the chain. Not all
	// chain starts at the same block number, so you might get an higher block than
	// requested when using default value of 0.
	//
	// Can be negative, will be resolved relative to the chain head block, assuming
	// a chain at head block #100, then using `-50` as the value will start at block
	// #50. If it resolves before first streamable block of chain, we assume start
	// of chain.
	//
	// If `start_cursor` is passed, this value is ignored and the stream instead starts
	// immediately after the Block pointed by the opaque `start_cursor` value.
	StartBlockNum int64 `protobuf:"varint,1,opt,name=start_block_num,json=startBlockNum,proto3" json:"start_block_num,omitempty"`
	// Controls where the stream of blocks will start which will be immediately after
	// the Block pointed by this opaque cursor.
	//
	// Obtain this value from a previously received `Response.cursor`.
	//
	// This value takes precedence over `start_block_num`.
	StartCursor string `protobuf:"bytes,13,opt,name=start_cursor,json=startCursor,proto3" json:"start_cursor,omitempty"`
	// When non-zero, controls where the stream of blocks will stop.
	//
	// The stream will close **after** that block has passed so the boundary is
	// **inclusive**.
	StopBlockNum uint64 `protobuf:"varint,5,opt,name=stop_block_num,json=stopBlockNum,proto3" json:"stop_block_num,omitempty"`
	// Filter the steps you want to see. If not specified, defaults to all steps.
	//
	// Most common steps will be [STEP_IRREVERSIBLE], or [STEP_NEW, STEP_UNDO, STEP_IRREVERSIBLE].
	ForkSteps []ForkStep `protobuf:"varint,8,rep,packed,name=fork_steps,json=forkSteps,proto3,enum=sf.firehose.v1.ForkStep" json:"fork_steps,omitempty"`
	// feature moved to transforms
	//
	// Deprecated: Do not use.
	IncludeFilterExpr string `protobuf:"bytes,10,opt,name=include_filter_expr,json=includeFilterExpr,proto3" json:"include_filter_expr,omitempty"`
	// Deprecated: Do not use.
	ExcludeFilterExpr string `protobuf:"bytes,11,opt,name=exclude_filter_expr,json=excludeFilterExpr,proto3" json:"exclude_filter_expr,omitempty"`
	//- EOS "handoffs:3"
	//- EOS "lib"
	//- EOS "confirms:3"
	//- ETH "confirms:200"
	//- ETH "confirms:7"
	//- SOL "commmitement:finalized"
	//- SOL "confirms:200"
	IrreversibilityCondition string       `` /* 134-byte string literal not displayed */
	Transforms               []*anypb.Any `protobuf:"bytes,18,rep,name=transforms,proto3" json:"transforms,omitempty"`
	// contains filtered or unexported fields
}

type Response struct {

	// Chain specific block payload, one of:
	// - sf.eosio.codec.v1.Block
	// - sf.ethereum.codec.v1.Block
	// - sf.near.codec.v1.Block
	// - sf.solana.codec.v1.Block
	Block  *anypb.Any `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	Step   ForkStep   `protobuf:"varint,6,opt,name=step,proto3,enum=sf.firehose.v1.ForkStep" json:"step,omitempty"`
	Cursor string     `protobuf:"bytes,10,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

type StreamClient interface {
	Blocks(ctx context.Context, in *Request, opts ...grpc.CallOption) (Stream_BlocksClient, error)
}

type StreamServer interface {
	Blocks(*Request, Stream_BlocksServer) error
}

type Stream_BlocksClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type Stream_BlocksServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type UnimplementedStreamServer struct {
}

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