runner

Documentation

Index

• func ExecuteFromArgs(ctx context.Context, platform string, clientCode *rkcy.ClientCode, ...)
• func RegisterNewRunnableFunc(name string, newRunnableFunc NewRunnableFunc)
• type CustomCommandFunc
• type NewRunnableFunc
  • func GetNewRunnableFunc(name string) NewRunnableFunc
• type OfflineRunner
  • func NewOfflineRunner(platformDefJson []byte, configJson []byte, clientCode *rkcy.ClientCode) (*OfflineRunner, error)
  • func (ornr *OfflineRunner) Close()
  • func (ornr *OfflineRunner) ExecuteTxnSync(txn *rkcy.Txn) (*rkcy.ResultProto, error)
  • func (ornr *OfflineRunner) OfflineManager() *offline.Manager
  • func (ornr *OfflineRunner) Platform() *platform.Platform
• type RkcyCmd
  • func NewRkcyCmd(ctx context.Context, platform string) *RkcyCmd
  • func (rkcycmd *RkcyCmd) AddCobraCommandFunc(custCmdFunc CustomCommandFunc)
  • func (rkcycmd *RkcyCmd) AddCobraConsumerCommandFunc(custCmdFunc CustomCommandFunc)
  • func (rkcycmd *RkcyCmd) AddCobraEdgeCommandFunc(custCmdFunc CustomCommandFunc)
  • func (rkcycmd *RkcyCmd) AddCrudHandler(concern string, storageType string, handler interface{})
  • func (rkcycmd *RkcyCmd) AddLogicHandler(concern string, handler interface{})
  • func (rkcycmd *RkcyCmd) AddStorageInit(storageType string, storageInit rkcy.StorageInit)
  • func (rkcycmd *RkcyCmd) BuildCobraCommand() *cobra.Command
  • func (rkcycmd *RkcyCmd) Execute() error
  • func (rkcycmd *RkcyCmd) Platform() *platform.Platform
  • func (rkcycmd *RkcyCmd) RunConsumerPrograms(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• type Settings

Functions

func ExecuteFromArgs

func ExecuteFromArgs(
	ctx context.Context,
	platform string,
	clientCode *rkcy.ClientCode,
	customCommandFuncs []CustomCommandFunc,
	offlineMgr *offline.Manager,
	args []string,
)

func RegisterNewRunnableFunc

func RegisterNewRunnableFunc(name string, newRunnableFunc NewRunnableFunc)

Types

type CustomCommandFunc

type CustomCommandFunc func(rkcycmd *RkcyCmd) *cobra.Command

type NewRunnableFunc

type NewRunnableFunc func(
	ctx context.Context,
	dets *program.Details,
) (program.Runnable, error)

func GetNewRunnableFunc

func GetNewRunnableFunc(name string) NewRunnableFunc

type OfflineRunner

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

func NewOfflineRunner

func NewOfflineRunner(
	platformDefJson []byte,
	configJson []byte,
	clientCode *rkcy.ClientCode,
) (*OfflineRunner, error)

func (*OfflineRunner) Close

func (ornr *OfflineRunner) Close()

func (*OfflineRunner) ExecuteTxnSync

func (ornr *OfflineRunner) ExecuteTxnSync(txn *rkcy.Txn) (*rkcy.ResultProto, error)

func (*OfflineRunner) OfflineManager

func (ornr *OfflineRunner) OfflineManager() *offline.Manager

func (*OfflineRunner) Platform

func (ornr *OfflineRunner) Platform() *platform.Platform

type RkcyCmd

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

func NewRkcyCmd

func NewRkcyCmd(ctx context.Context, platform string) *RkcyCmd

func (*RkcyCmd) AddCobraCommandFunc

func (rkcycmd *RkcyCmd) AddCobraCommandFunc(custCmdFunc CustomCommandFunc)

func (*RkcyCmd) AddCobraConsumerCommandFunc

func (rkcycmd *RkcyCmd) AddCobraConsumerCommandFunc(custCmdFunc CustomCommandFunc)

func (*RkcyCmd) AddCobraEdgeCommandFunc

func (rkcycmd *RkcyCmd) AddCobraEdgeCommandFunc(custCmdFunc CustomCommandFunc)

func (*RkcyCmd) AddCrudHandler

func (rkcycmd *RkcyCmd) AddCrudHandler(
	concern string,
	storageType string,
	handler interface{},
)

func (*RkcyCmd) AddLogicHandler

func (rkcycmd *RkcyCmd) AddLogicHandler(
	concern string,
	handler interface{},
)

func (*RkcyCmd) AddStorageInit

func (rkcycmd *RkcyCmd) AddStorageInit(storageType string, storageInit rkcy.StorageInit)

func (*RkcyCmd) BuildCobraCommand

func (rkcycmd *RkcyCmd) BuildCobraCommand() *cobra.Command

func (*RkcyCmd) Execute

func (rkcycmd *RkcyCmd) Execute() error

func (*RkcyCmd) Platform

func (rkcycmd *RkcyCmd) Platform() *platform.Platform

func (*RkcyCmd) RunConsumerPrograms

func (rkcycmd *RkcyCmd) RunConsumerPrograms(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	platform string,
	environment string,
	adminBrokers string,
	otelcolEndpoint string,
	watchDecode bool,
)

type Settings

type Settings struct {
	PlatformFilePath string
	ConfigFilePath   string

	OtelcolEndpoint string

	Environment     string
	AdminBrokers    string
	ConsumerBrokers string

	HttpAddr string
	GrpcAddr string

	Topic     string
	Partition int32

	Edge bool

	AdminPingIntervalSecs uint

	StorageTarget string

	WatchDecode bool

	StreamType string
	RunnerType string
}