Method SaveCommit

service/upstream/iml.go:83–85

(ctx context.Context, uid string, partition string, cfg *Config)

}

func (i *imlUpstreamService) SaveCommit(ctx context.Context, uid string, partition string, cfg *Config) error {
	return i.commitService.Save(ctx, uid, partition, cfg)
}

func (i *imlUpstreamService) OnComplete() {