platform

Documentation

Index

• func ConsumeResponseTopic(ctx context.Context, wg *sync.WaitGroup, strmprov rkcy.StreamProvider, ...)
• type Platform
  • func NewPlatform(ctx context.Context, wg *sync.WaitGroup, id string, platform string, ...) (*Platform, error)
  • func (plat *Platform) ConfigMgr() *config_mgr.ConfigMgr
  • func (plat *Platform) ConfigRdr() rkcy.ConfigRdr
  • func (plat *Platform) Context() context.Context
  • func (plat *Platform) GetProducerCh(ctx context.Context, wg *sync.WaitGroup, brokers string) rkcy.ProducerCh
  • func (plat *Platform) InitConfigMgr(ctx context.Context)
  • func (plat *Platform) NewManagedProducer(ctx context.Context, wg *sync.WaitGroup, concernName string, topicName string) *stream.ManagedProducer
  • func (plat *Platform) RegisterResponseChannel(respCh *RespChan)
  • func (plat *Platform) ResponseTarget() *rkcypb.TopicTarget
  • func (plat *Platform) StreamProvider() rkcy.StreamProvider
  • func (plat *Platform) UpdateStorageTargets(platMsg *mgmt.PlatformMessage)
  • func (plat *Platform) WaitGroup() *sync.WaitGroup
• type RespChan

Functions

func ConsumeResponseTopic

func ConsumeResponseTopic(
	ctx context.Context,
	wg *sync.WaitGroup,
	strmprov rkcy.StreamProvider,
	respTarget *rkcypb.TopicTarget,
	respRegisterCh <-chan *RespChan,
)

Types

type Platform

type Platform struct {
	Args *rkcy.PlatformArgs

	ApecsProducer *stream.ApecsProducer

	RtPlatformDef *rkcy.RtPlatformDef

	InstanceStore *rkcy.InstanceStore

	ClientCode *rkcy.ClientCode
	// contains filtered or unexported fields
}

func NewPlatform

func NewPlatform(
	ctx context.Context,
	wg *sync.WaitGroup,
	id string,
	platform string,
	environment string,
	adminBrokers string,
	adminPingInterval time.Duration,
	strmprov rkcy.StreamProvider,
	clientCode *rkcy.ClientCode,
	respTarget *rkcypb.TopicTarget,
) (*Platform, error)

func (*Platform) ConfigMgr

func (plat *Platform) ConfigMgr() *config_mgr.ConfigMgr

func (*Platform) ConfigRdr

func (plat *Platform) ConfigRdr() rkcy.ConfigRdr

func (*Platform) Context

func (plat *Platform) Context() context.Context

func (*Platform) GetProducerCh

func (plat *Platform) GetProducerCh(
	ctx context.Context,
	wg *sync.WaitGroup,
	brokers string,
) rkcy.ProducerCh

func (*Platform) InitConfigMgr

func (plat *Platform) InitConfigMgr(ctx context.Context)

func (*Platform) NewManagedProducer

func (plat *Platform) NewManagedProducer(
	ctx context.Context,
	wg *sync.WaitGroup,
	concernName string,
	topicName string,
) *stream.ManagedProducer

func (*Platform) RegisterResponseChannel

func (plat *Platform) RegisterResponseChannel(respCh *RespChan)

func (*Platform) ResponseTarget

func (plat *Platform) ResponseTarget() *rkcypb.TopicTarget

func (*Platform) StreamProvider

func (plat *Platform) StreamProvider() rkcy.StreamProvider

func (*Platform) UpdateStorageTargets

func (plat *Platform) UpdateStorageTargets(platMsg *mgmt.PlatformMessage)

func (*Platform) WaitGroup

func (plat *Platform) WaitGroup() *sync.WaitGroup

type RespChan

type RespChan struct {
	TxnId     string
	RespCh    chan *rkcypb.ApecsTxn
	StartTime time.Time
}