custom

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCodec = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCodec   = fmt.Errorf("proto: integer overflow")
)
View Source 
var InnerStateEnum_name = map[int32]string{
	0: "INNER_STATE_ENUM_INVALID",
	1: "INNER_STATE_ENUM_CASE_1",
	2: "INNER_STATE_ENUM_CASE_2",
}
View Source 
var InnerStateEnum_value = map[string]int32{
	"INNER_STATE_ENUM_INVALID": 0,
	"INNER_STATE_ENUM_CASE_1":  1,
	"INNER_STATE_ENUM_CASE_2":  2,
}

Functions

func NewCreateStateHandler 

func NewCreateStateHandler(auth x.Authenticator) weave.Handler

NewCreateStateHandler creates a handler

func NewCreateTimedStateHandler 

func NewCreateTimedStateHandler(auth x.Authenticator, scheduler weave.Scheduler) weave.Handler

NewCreateTimedStateHandler creates a handler

func RegisterCronRoutes 

func RegisterCronRoutes(
	r weave.Registry,
	auth x.Authenticator,
)

RegisterCronRoutes registers routes that are not exposed to routers

func RegisterQuery 

func RegisterQuery(qr weave.QueryRouter)

RegisterQuery registers buckets for querying.

func RegisterRoutes 

func RegisterRoutes(r weave.Registry, auth x.Authenticator, scheduler weave.Scheduler)

RegisterRoutes registers handlers for message processing.

Types

type CreateStateHandler 

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

CreateStateHandler will handle creating custom state buckets

func (CreateStateHandler) Check 

func (h CreateStateHandler) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx) (*weave.CheckResult, error)

Check just verifies it is properly formed and returns the cost of executing it.

func (CreateStateHandler) Deliver 

func (h CreateStateHandler) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx) (*weave.DeliverResult, error)

Deliver creates an custom state and saves if all preconditions are met

type CreateStateMsg 

type CreateStateMsg struct {
	Metadata   *weave.Metadata                  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	InnerState *InnerState                      `protobuf:"bytes,2,opt,name=inner_state,json=innerState,proto3" json:"inner_state,omitempty"`
	Address    github_com_iov_one_weave.Address `protobuf:"bytes,3,opt,name=address,proto3,casttype=github.com/iov-one/weave.Address" json:"address,omitempty"`
}

func (*CreateStateMsg) Descriptor 

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

func (*CreateStateMsg) GetAddress 

func (m *CreateStateMsg) GetAddress() github_com_iov_one_weave.Address

func (*CreateStateMsg) GetInnerState 

func (m *CreateStateMsg) GetInnerState() *InnerState

func (*CreateStateMsg) GetMetadata 

func (m *CreateStateMsg) GetMetadata() *weave.Metadata

func (*CreateStateMsg) Marshal 

func (m *CreateStateMsg) Marshal() (dAtA []byte, err error)

func (*CreateStateMsg) MarshalTo 

func (m *CreateStateMsg) MarshalTo(dAtA []byte) (int, error)

func (CreateStateMsg) Path 

func (CreateStateMsg) Path() string

Path returns the routing path for this message.

func (*CreateStateMsg) ProtoMessage 

func (*CreateStateMsg) ProtoMessage()

func (*CreateStateMsg) Reset 

func (m *CreateStateMsg) Reset()

func (*CreateStateMsg) Size 

func (m *CreateStateMsg) Size() (n int)

func (*CreateStateMsg) String 

func (m *CreateStateMsg) String() string

func (*CreateStateMsg) Unmarshal 

func (m *CreateStateMsg) Unmarshal(dAtA []byte) error

func (CreateStateMsg) Validate 

func (m CreateStateMsg) Validate() error

Validate ensures the CreateStateMsg is valid

func (*CreateStateMsg) XXX_DiscardUnknown 

func (m *CreateStateMsg) XXX_DiscardUnknown()

func (*CreateStateMsg) XXX_Marshal 

func (m *CreateStateMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateStateMsg) XXX_Merge 

func (m *CreateStateMsg) XXX_Merge(src proto.Message)

func (*CreateStateMsg) XXX_Size 

func (m *CreateStateMsg) XXX_Size() int

func (*CreateStateMsg) XXX_Unmarshal 

func (m *CreateStateMsg) XXX_Unmarshal(b []byte) error

type CreateTimedStateHandler 

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

CreateTimedStateHandler will handle creating custom indexed state buckets

func (CreateTimedStateHandler) Check 

func (h CreateTimedStateHandler) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx) (*weave.CheckResult, error)

Check just verifies it is properly formed and returns the cost of executing it.

func (CreateTimedStateHandler) Deliver 

func (h CreateTimedStateHandler) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx) (*weave.DeliverResult, error)

Deliver creates an custom state and saves if all preconditions are met

type CreateTimedStateMsg 

type CreateTimedStateMsg struct {
	Metadata       *weave.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	InnerStateEnum InnerStateEnum  `` /* 133-byte string literal not displayed */
	Str            string          `protobuf:"bytes,3,opt,name=str,proto3" json:"str,omitempty"`
	Byte           []byte          `protobuf:"bytes,4,opt,name=byte,proto3" json:"byte,omitempty"`
	// DeleteAt is a deletion event that will take place in future
	// Demonstrates cron usage
	DeleteAt github_com_iov_one_weave.UnixTime `` /* 129-byte string literal not displayed */
}

func (*CreateTimedStateMsg) Descriptor 

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

func (*CreateTimedStateMsg) GetByte 

func (m *CreateTimedStateMsg) GetByte() []byte

func (*CreateTimedStateMsg) GetDeleteAt 

func (m *CreateTimedStateMsg) GetDeleteAt() github_com_iov_one_weave.UnixTime

func (*CreateTimedStateMsg) GetInnerStateEnum 

func (m *CreateTimedStateMsg) GetInnerStateEnum() InnerStateEnum

func (*CreateTimedStateMsg) GetMetadata 

func (m *CreateTimedStateMsg) GetMetadata() *weave.Metadata

func (*CreateTimedStateMsg) GetStr 

func (m *CreateTimedStateMsg) GetStr() string

func (*CreateTimedStateMsg) Marshal 

func (m *CreateTimedStateMsg) Marshal() (dAtA []byte, err error)

func (*CreateTimedStateMsg) MarshalTo 

func (m *CreateTimedStateMsg) MarshalTo(dAtA []byte) (int, error)

func (CreateTimedStateMsg) Path 

func (CreateTimedStateMsg) Path() string

Path returns the routing path for this message.

func (*CreateTimedStateMsg) ProtoMessage 

func (*CreateTimedStateMsg) ProtoMessage()

func (*CreateTimedStateMsg) Reset 

func (m *CreateTimedStateMsg) Reset()

func (*CreateTimedStateMsg) Size 

func (m *CreateTimedStateMsg) Size() (n int)

func (*CreateTimedStateMsg) String 

func (m *CreateTimedStateMsg) String() string

func (*CreateTimedStateMsg) Unmarshal 

func (m *CreateTimedStateMsg) Unmarshal(dAtA []byte) error

func (CreateTimedStateMsg) Validate 

func (m CreateTimedStateMsg) Validate() error

Validate ensures the CreateTimedStateMsg is valid

func (*CreateTimedStateMsg) XXX_DiscardUnknown 

func (m *CreateTimedStateMsg) XXX_DiscardUnknown()

func (*CreateTimedStateMsg) XXX_Marshal 

func (m *CreateTimedStateMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTimedStateMsg) XXX_Merge 

func (m *CreateTimedStateMsg) XXX_Merge(src proto.Message)

func (*CreateTimedStateMsg) XXX_Size 

func (m *CreateTimedStateMsg) XXX_Size() int

func (*CreateTimedStateMsg) XXX_Unmarshal 

func (m *CreateTimedStateMsg) XXX_Unmarshal(b []byte) error

type DeleteTimedStateHandler 

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

DeleteTimedStateHandler will handle deleting timed state

func (DeleteTimedStateHandler) Check 

func (h DeleteTimedStateHandler) Check(ctx weave.Context, store weave.KVStore, tx weave.Tx) (*weave.CheckResult, error)

Check just verifies it is properly formed and returns the cost of executing it.

func (DeleteTimedStateHandler) Deliver 

func (h DeleteTimedStateHandler) Deliver(ctx weave.Context, store weave.KVStore, tx weave.Tx) (*weave.DeliverResult, error)

Deliver delete state if all preconditions are met

type DeleteTimedStateMsg 

type DeleteTimedStateMsg struct {
	Metadata     *weave.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	TimedStateID []byte          `protobuf:"bytes,2,opt,name=timed_state_id,json=timedStateId,proto3" json:"timed_state_id,omitempty"`
}

func (*DeleteTimedStateMsg) Descriptor 

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

func (*DeleteTimedStateMsg) GetMetadata 

func (m *DeleteTimedStateMsg) GetMetadata() *weave.Metadata

func (*DeleteTimedStateMsg) GetTimedStateID 

func (m *DeleteTimedStateMsg) GetTimedStateID() []byte

func (*DeleteTimedStateMsg) Marshal 

func (m *DeleteTimedStateMsg) Marshal() (dAtA []byte, err error)

func (*DeleteTimedStateMsg) MarshalTo 

func (m *DeleteTimedStateMsg) MarshalTo(dAtA []byte) (int, error)

func (DeleteTimedStateMsg) Path 

func (DeleteTimedStateMsg) Path() string

Path returns the routing path for this message.

func (*DeleteTimedStateMsg) ProtoMessage 

func (*DeleteTimedStateMsg) ProtoMessage()

func (*DeleteTimedStateMsg) Reset 

func (m *DeleteTimedStateMsg) Reset()

func (*DeleteTimedStateMsg) Size 

func (m *DeleteTimedStateMsg) Size() (n int)

func (*DeleteTimedStateMsg) String 

func (m *DeleteTimedStateMsg) String() string

func (*DeleteTimedStateMsg) Unmarshal 

func (m *DeleteTimedStateMsg) Unmarshal(dAtA []byte) error

func (DeleteTimedStateMsg) Validate 

func (m DeleteTimedStateMsg) Validate() error

Validate ensures the DeleteTimedStateMsg is valid

func (*DeleteTimedStateMsg) XXX_DiscardUnknown 

func (m *DeleteTimedStateMsg) XXX_DiscardUnknown()

func (*DeleteTimedStateMsg) XXX_Marshal 

func (m *DeleteTimedStateMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTimedStateMsg) XXX_Merge 

func (m *DeleteTimedStateMsg) XXX_Merge(src proto.Message)

func (*DeleteTimedStateMsg) XXX_Size 

func (m *DeleteTimedStateMsg) XXX_Size() int

func (*DeleteTimedStateMsg) XXX_Unmarshal 

func (m *DeleteTimedStateMsg) XXX_Unmarshal(b []byte) error

type InnerState 

type InnerState struct {
	St1 int64 `protobuf:"varint,1,opt,name=st1,proto3" json:"st1,omitempty"`
	St2 int64 `protobuf:"varint,2,opt,name=st2,proto3" json:"st2,omitempty"`
}

func (*InnerState) Descriptor 

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

func (*InnerState) GetSt1 

func (m *InnerState) GetSt1() int64

func (*InnerState) GetSt2 

func (m *InnerState) GetSt2() int64

func (*InnerState) Marshal 

func (m *InnerState) Marshal() (dAtA []byte, err error)

func (*InnerState) MarshalTo 

func (m *InnerState) MarshalTo(dAtA []byte) (int, error)

func (*InnerState) ProtoMessage 

func (*InnerState) ProtoMessage()

func (*InnerState) Reset 

func (m *InnerState) Reset()

func (*InnerState) Size 

func (m *InnerState) Size() (n int)

func (*InnerState) String 

func (m *InnerState) String() string

func (*InnerState) Unmarshal 

func (m *InnerState) Unmarshal(dAtA []byte) error

func (*InnerState) XXX_DiscardUnknown 

func (m *InnerState) XXX_DiscardUnknown()

func (*InnerState) XXX_Marshal 

func (m *InnerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InnerState) XXX_Merge 

func (m *InnerState) XXX_Merge(src proto.Message)

func (*InnerState) XXX_Size 

func (m *InnerState) XXX_Size() int

func (*InnerState) XXX_Unmarshal 

func (m *InnerState) XXX_Unmarshal(b []byte) error

type InnerStateEnum 

type InnerStateEnum int32
const (
	InnerStateEnum_Invalid InnerStateEnum = 0
	InnerStateEnum_CaseOne InnerStateEnum = 1
	InnerStateEnum_CaseTwo InnerStateEnum = 2
)

func (InnerStateEnum) EnumDescriptor 

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

func (InnerStateEnum) String 

func (x InnerStateEnum) String() string

type State 

type State struct {
	Metadata   *weave.Metadata                  `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	InnerState *InnerState                      `protobuf:"bytes,2,opt,name=inner_state,json=innerState,proto3" json:"inner_state,omitempty"`
	Address    github_com_iov_one_weave.Address `protobuf:"bytes,3,opt,name=address,proto3,casttype=github.com/iov-one/weave.Address" json:"address,omitempty"`
	// Demonstrates timestamp in models
	CreatedAt github_com_iov_one_weave.UnixTime `` /* 132-byte string literal not displayed */
}

func (*State) Copy 

func (m *State) Copy() orm.CloneableData

Copy produces a new State clone to fulfill the Model interface

func (*State) Descriptor 

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

func (*State) GetAddress 

func (m *State) GetAddress() github_com_iov_one_weave.Address

func (*State) GetCreatedAt 

func (m *State) GetCreatedAt() github_com_iov_one_weave.UnixTime

func (*State) GetInnerState 

func (m *State) GetInnerState() *InnerState

func (*State) GetMetadata 

func (m *State) GetMetadata() *weave.Metadata

func (*State) Marshal 

func (m *State) Marshal() (dAtA []byte, err error)

func (*State) MarshalTo 

func (m *State) MarshalTo(dAtA []byte) (int, error)

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) Size 

func (m *State) Size() (n int)

func (*State) String 

func (m *State) String() string

func (*State) Unmarshal 

func (m *State) Unmarshal(dAtA []byte) error

func (*State) Validate 

func (m *State) Validate() error

Validate ensures the State fields are valid

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

func (m *State) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*State) XXX_Merge 

func (m *State) XXX_Merge(src proto.Message)

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

func (m *State) XXX_Unmarshal(b []byte) error

type StateBucket 

type StateBucket struct {
	orm.ModelBucket
}

func NewStateBucket 

func NewStateBucket() *StateBucket

type TimedState 

type TimedState struct {
	Metadata       *weave.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	InnerStateEnum InnerStateEnum  `` /* 133-byte string literal not displayed */
	Str            string          `protobuf:"bytes,3,opt,name=str,proto3" json:"str,omitempty"`
	Byte           []byte          `protobuf:"bytes,4,opt,name=byte,proto3" json:"byte,omitempty"`
	// DeleteAt is a deletion event that will take place in future
	// Demonstrates cron usage
	DeleteAt github_com_iov_one_weave.UnixTime `` /* 129-byte string literal not displayed */
}

func (*TimedState) Copy 

func (m *TimedState) Copy() orm.CloneableData

Copy produces a new TimedState clone to fulfill the Model interface

func (*TimedState) Descriptor 

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

func (*TimedState) GetByte 

func (m *TimedState) GetByte() []byte

func (*TimedState) GetDeleteAt 

func (m *TimedState) GetDeleteAt() github_com_iov_one_weave.UnixTime

func (*TimedState) GetInnerStateEnum 

func (m *TimedState) GetInnerStateEnum() InnerStateEnum

func (*TimedState) GetMetadata 

func (m *TimedState) GetMetadata() *weave.Metadata

func (*TimedState) GetStr 

func (m *TimedState) GetStr() string

func (*TimedState) Marshal 

func (m *TimedState) Marshal() (dAtA []byte, err error)

func (*TimedState) MarshalTo 

func (m *TimedState) MarshalTo(dAtA []byte) (int, error)

func (*TimedState) ProtoMessage 

func (*TimedState) ProtoMessage()

func (*TimedState) Reset 

func (m *TimedState) Reset()

func (*TimedState) Size 

func (m *TimedState) Size() (n int)

func (*TimedState) String 

func (m *TimedState) String() string

func (*TimedState) Unmarshal 

func (m *TimedState) Unmarshal(dAtA []byte) error

func (*TimedState) Validate 

func (m *TimedState) Validate() error

Validate ensures the TimedState fields are valid

func (*TimedState) XXX_DiscardUnknown 

func (m *TimedState) XXX_DiscardUnknown()

func (*TimedState) XXX_Marshal 

func (m *TimedState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimedState) XXX_Merge 

func (m *TimedState) XXX_Merge(src proto.Message)

func (*TimedState) XXX_Size 

func (m *TimedState) XXX_Size() int

func (*TimedState) XXX_Unmarshal 

func (m *TimedState) XXX_Unmarshal(b []byte) error

type TimedStateBucket 

type TimedStateBucket struct {
	orm.ModelBucket
}

func NewTimedStateBucket 

func NewTimedStateBucket() *TimedStateBucket

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.